[
https://issues.apache.org/jira/browse/KAFKA-242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-242:
-------------------------------
Attachment: kafka.log
Annotated log messages from two different test runs. For each test run, 20k
messages were written to "mytopic" and "mytopic1" each with no consumers
running. Once the messages had all been sent, the consumers were started up
> 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 is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
