kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ted Yu (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-5898) Client consume more than one time a message
Date Thu, 14 Sep 2017 23:53:00 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167127#comment-16167127
] 

Ted Yu commented on KAFKA-5898:
-------------------------------

Just curious: 0.11.0.1 has been released.

Is this reproducible using 0.11.0.1 ?

> Client consume more than one time a message
> -------------------------------------------
>
>                 Key: KAFKA-5898
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5898
>             Project: Kafka
>          Issue Type: Bug
>          Components: clients
>    Affects Versions: 0.11.0.0
>            Reporter: Cyril WIRTH
>            Priority: Critical
>         Attachments: AbstractKafkaConfig.java, consommation.log, MyKafkaClient.java,
MyProducer.java, production.log
>
>
> Hello,
> I'm using an autocommit consumer, i get some messages, and my SESSION_TIMEOUT_MS_CONFIG
is smaller than the total message processing time. In that case, the consumer consume more
than one time a message (twice in the log file), how it's possible ? As you can see in the
log file, the "msg1" which is in the partition 0 is consume in the same time in the thread
: KAFKA-0 and KAFKA-1, however the KAFKA-1 is assigned to the partition 1 not 0.
> KAFKA-0,assigned : [vertx_logger-0]
> KAFKA-2,assigned : [vertx_logger-2]
> KAFKA-1,assigned : [vertx_logger-1]
> Can you help me ?



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message