[ 
https://issues.apache.org/jira/browse/KAFKA-1137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13891201#comment-13891201
 ] 

Neha Narkhede commented on KAFKA-1137:
--------------------------------------

Updated reviewboard https://reviews.apache.org/r/17649/
 against branch trunk

> 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.0
>            Reporter: aio
>            Assignee: Neha Narkhede
>         Attachments: KAFKA-1137_2014-02-04_13:04:23.patch
>
>
> 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.5#6160)

Reply via email to