Uploaded image for project: 'Camel'
  1. Camel
  2. CAMEL-12454

camel-kafka - AutoCommitEnabled=false should not auto commit

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 2.20.3, 2.21.0
    • 2.20.4, 2.21.1, 2.22.0
    • camel-kafka
    • None
    • Unknown

    Description

      Reported on gitter

      John Culleton @jcullet Apr 17 17:22
      Hi All - I'm running into an issue with the camel-kafka component when attempting to disable auto commit behavior. On camel 2.21, I'm finding that the offset is being committed even when "autoCommitEnable=false" is specified. When running through a debugger, I see that the offset commit is happening here: https://github.com/apache/camel/blob/0f98938e3b6ea15a2e022c707bf21a2af4ed7e0d/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java#L382. Based on the conditional, I think it would always evaluate to true when autoCommitEnable is set to false?

      Attachments

        Activity

          People

            davsclaus Claus Ibsen
            davsclaus Claus Ibsen
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: