Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5898

Client consume more than one time a message

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Critical
    • Resolution: Unresolved
    • 0.11.0.0
    • None
    • clients
    • None

    Description

      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 ?

      Attachments

        1. production.log
          7 kB
          Cyril WIRTH
        2. MyProducer.java
          2 kB
          Cyril WIRTH
        3. MyKafkaClient.java
          3 kB
          Cyril WIRTH
        4. consommation.log
          7 kB
          Cyril WIRTH
        5. AbstractKafkaConfig.java
          2 kB
          Cyril WIRTH

        Activity

          People

            Unassigned Unassigned
            Cyril WIRTH Cyril WIRTH
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: