This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot_3x in repository https://gitbox.apache.org/repos/asf/camel.git
from 781ced5c01b (chores) camel-tooling-util: fixed checkstyle (#11992) add aef4ddd7491 CAMEL-20044: add extra logging for BreakOnFirstError (#11920) add db216e4408a CAMEL-20044: fix to handle commit on breakOnFirstError (#11959) add 9cab8c22fe8 Regen for commit db216e4408a084d3125b93db3a561f6ce91ac04b No new revisions were added by this update. Summary of changes: .../org/apache/camel/catalog/components/kafka.json | 4 +- .../org/apache/camel/component/kafka/kafka.json | 4 +- .../camel-kafka/src/main/docs/kafka-component.adoc | 46 ++++- .../camel/component/kafka/KafkaConfiguration.java | 13 +- .../camel/component/kafka/KafkaFetchRecords.java | 32 +++- .../kafka/consumer/AbstractCommitManager.java | 2 + .../consumer/support/KafkaRecordProcessor.java | 48 ++++-- .../support/KafkaRecordProcessorFacade.java | 10 ++ .../kafka/consumer/support/ProcessingResult.java | 13 +- ...eakOnFirstErrorOffUsingKafkaManualCommitIT.java | 162 ++++++++++++++++++ .../KafkaBreakOnFirstErrorReplayOldMessagesIT.java | 190 +++++++++++++++++++++ .../KafkaBreakOnFirstErrorSeekIssueIT.java | 171 +++++++++++++++++++ ...stErrorWithBatchUsingAsynchCommitManagerIT.java | 155 +++++++++++++++++ ...irstErrorWithBatchUsingKafkaManualCommitIT.java | 172 +++++++++++++++++++ ...rrorWithBatchUsingKafkaManualCommitRetryIT.java | 176 +++++++++++++++++++ ...rstErrorWithBatchUsingSynchCommitManagerIT.java | 155 +++++++++++++++++ .../component/kafka/testutil/CamelKafkaUtil.java | 57 +++++++ .../ROOT/pages/camel-3x-upgrade-guide-3_21.adoc | 16 ++ .../dsl/KafkaComponentBuilderFactory.java | 16 +- 19 files changed, 1411 insertions(+), 31 deletions(-) create mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java create mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java create mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java create mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT.java create mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java create mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java create mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSynchCommitManagerIT.java create mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/testutil/CamelKafkaUtil.java