Hi,
    I am now using kafka0.8, i have problem with FetchRequest API (
https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-FetchRequest),
the detail of the problem as follow:
I send two FetchRequest [topic, partition, maxWaitTime] through 1 socket
connection, minBytes is set 1,  each request hold a different topic (topic1
and topic2), the maxWatiTime are same(30 seconds), as we know, if a topic
(topic1) have new produced message, kafka server should write back data to
the socket immediately, but the fact is server write back data only when
topic2 has new message, otherwise i have to wait 30s to get the new message
in topic1.Is this a bug of kafka server , or it was designed like this?

Thanks.

Reply via email to