kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ylzhang (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-242) Subsequent calls of ConsumerConnector.createMessageStreams cause Consumer offset to be incorrect
Date Wed, 20 Sep 2017 06:51:03 GMT

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

Mime
View raw message