This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 6ce1425168a CAMEL-20132: ensures the loggers match their enclosing
classes
add 12591b293a2 CAMEL-20044: backport breakOnFirstError Fix to Camel 4
(#12004)
No new revisions were added by this update.
Summary of changes:
.../org/apache/camel/catalog/components/kafka.json | 4 +-
components/camel-kafka/pom.xml | 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 | 161 +++++++++++++++++
.../KafkaBreakOnFirstErrorReplayOldMessagesIT.java | 191 +++++++++++++++++++++
.../KafkaBreakOnFirstErrorSeekIssueIT.java | 173 +++++++++++++++++++
...stErrorWithBatchUsingAsynchCommitManagerIT.java | 154 +++++++++++++++++
...irstErrorWithBatchUsingKafkaManualCommitIT.java | 172 +++++++++++++++++++
...rrorWithBatchUsingKafkaManualCommitRetryIT.java | 176 +++++++++++++++++++
...rstErrorWithBatchUsingSynchCommitManagerIT.java | 154 +++++++++++++++++
.../component/kafka/testutil/CamelKafkaUtil.java | 57 ++++++
.../ROOT/pages/camel-3x-upgrade-guide-3_21.adoc | 16 ++
.../ROOT/pages/camel-4x-upgrade-guide-4_3.adoc | 13 ++
20 files changed, 1416 insertions(+), 27 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
