[ https://issues.apache.org/jira/browse/KAFKA-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16172826#comment-16172826 ]
ylzhang commented on KAFKA-242: ------------------------------- can upgrade and use new consumer, you can get it from https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Detailed+Consumer+Coordinator+Design > Subsequent calls of ConsumerConnector.createMessageStreams cause Consumer > offset to be incorrect > ------------------------------------------------------------------------------------------------ > > Key: KAFKA-242 > URL: https://issues.apache.org/jira/browse/KAFKA-242 > Project: Kafka > Issue Type: Bug > Components: clients > Affects Versions: 0.7 > Reporter: David Arthur > Attachments: kafka.log > > > When calling ConsumerConnector.createMessageStreams in rapid succession, the > Consumer offset is incorrectly advanced causing the consumer to lose > messages. This seems to happen when createMessageStreams is called before the > rebalancing triggered by the previous call to createMessageStreams has > completed. -- This message was sent by Atlassian JIRA (v6.4.14#64029)