[ 
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)

Reply via email to