Uploaded image for project: 'Red Hat build of Apache Camel for Spring Boot'
  1. Red Hat build of Apache Camel for Spring Boot
  2. CSB-7796

Support camel-kafka "breakOnFirstError=true" with "batching=true"

XMLWordPrintable

    • Icon: Story Story
    • Resolution: Done
    • Icon: Normal Normal
    • CSB-4.14
    • CSB-4.10.6
    • Camel
    • None
    • False
    • Hide

      None

      Show
      None
    • False
    • Very Likely
    • 0

      • "breakOnFirstError=true" and "batching=false" // It works as expected
        • When Exception occurs, the Kafka consumer reconnects client with following logs. 
          2025-09-18T18:25:34.411+09:00  INFO 24168 --- [mer[test-break]] o.a.c.component.kafka.KafkaFetchRecords  : Reconnecting Kafka consumer thread ID test-break-Thread 0 with poll timeout of 1000 ms
2025-09-18T18:25:34.411+09:00  INFO 24168 --- [mer[test-break]] o.a.k.clients.consumer.ConsumerConfig    : ConsumerConfig values: 
	allow.auto.create.topics = true
    ...
      • "breakOnFirstError=true" and "batching=true"
        • When Exception occurs, Please let the Kafka consumer reconnects client to the broker too.
        • Users can implement from where they want to handle messages in their application with manual commit.

          There are no Sub-Tasks for this issue.

              acosenti Andrea Cosentino
              rhn-support-hfuruich Hisao Furuichi
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

                Created:
                Updated:
                Resolved: