kafka-jira mailing list archives

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

             Summary: 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:
            Reporter: Cyril WIRTH
            Priority: Critical
         Attachments: AbstractKafkaConfig.java, consommation.log, MyKafkaClient.java, MyProducer.java,

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

View raw message