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

Neha Narkhede commented on KAFKA-738:
-------------------------------------

We don't use the builder pattern the way it is supposed to be used. The builder 
is created once, setting the required values and calling build() happens 
multiple times. In our case, this is complicated because we maintain some state 
in the request map, but this can easily be resolved by providing a 
resetBuilder() API. That way, it will work for SimpleConsumer and high level 
consumer
                
> correlationId is not set in FetchRequest in AbstractFetcherThread
> -----------------------------------------------------------------
>
>                 Key: KAFKA-738
>                 URL: https://issues.apache.org/jira/browse/KAFKA-738
>             Project: Kafka
>          Issue Type: Bug
>          Components: core
>    Affects Versions: 0.8
>            Reporter: Jun Rao
>            Assignee: Jun Rao
>            Priority: Blocker
>              Labels: p2
>         Attachments: kafka-738.patch, kafka-738_v2.patch
>
>
> correlationId is always 0 in FetchRequest in AbstractFetcherThread.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

Reply via email to