[
https://issues.apache.org/jira/browse/KAFKA-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14624630#comment-14624630
]
Stefan Miklosovic commented on KAFKA-242:
-----------------------------------------
[~jkreps] I am hitting the same issues
I opened JIRA here https://issues.apache.org/jira/browse/KAFKA-2331
I am calling ConsumerConnector.createMessageStreams fastly and it seems that it
is not handling rebalancing of partitions correctly.
> 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.3.4#6332)
