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

Kafka offset advances when using Pausable EIP and messages are lost when resumed

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • 3.21.2
    • 4.x
    • camel-kafka
    • None
    • Moderate

    Description

      Kafka offset advances when using Pausable kafka consumer and messages are lost when resumed. 

      Attached is the sample code

      Also tried with 

      KafkaManualCommit manual = exchange.getIn().getHeader(KafkaConstants.MANUAL_COMMIT, KafkaManualCommit.class);
                  manual.commit();

      Attachments

        1. sample.txt
          2 kB
          Preetam Panchaksharaiah

        Activity

          People

            davsclaus Claus Ibsen
            preetam.ap Preetam Panchaksharaiah
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: