You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "aio (JIRA)" <ji...@apache.org> on 2013/11/21 03:56:38 UTC

[jira] [Created] (KAFKA-1137) Problem of FetchRequest API

aio created KAFKA-1137:
--------------------------

             Summary: Problem of FetchRequest API
                 Key: KAFKA-1137
                 URL: https://issues.apache.org/jira/browse/KAFKA-1137
             Project: Kafka
          Issue Type: Bug
          Components: consumer
    Affects Versions: 0.8
            Reporter: aio
            Assignee: Neha Narkhede


We meet this problem when use Fetch API [0] in Node.js client [1]. The detail of the problem as follow:
Send 2 FetchRequest in sequence through one long polling socket connection, each request hold one different topic (topic1 and topic2), topic2 is sent after topic1,MaxWaitTime set 30s, MinBytes set 1 byte. As the protocol doc said, when topic has new produced message, Kafka server would write back response to the socket, but the fact is Kafka server write response only when the last topic (topic2) has new message, otherwise we have to wait 30s to get the fetchResponse of topic1.

I think Kafka server only approve the the MaxWaitTime in last FetchRequest of one socket connection, but why respond the new message in all topic when the last request have message.

[0] : https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-FetchRequest
[1] : https://github.com/SOHU-Co/kafka-node



--
This message was sent by Atlassian JIRA
(v6.1#6144)