You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Cyril WIRTH (JIRA)" <ji...@apache.org> on 2017/09/14 22:03:00 UTC
[jira] [Created] (KAFKA-5898) Client consume more than one time a
message
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: 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)