[ 
https://issues.apache.org/jira/browse/KAFKA-242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Manikumar resolved KAFKA-242.
-----------------------------
    Resolution: Auto Closed

Closing inactive issue. The old consumer is no longer supported.

> 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