[ 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