This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git.
from dc1c250 [CAMEL-17391] Update elasticsearch-rest documentation add cc68891 CAMEL-15562: reorganize code to simplify providing out-of-the-box resume strategies add 9bdbf7b CAMEL-15562: created a commit manager in camel-kafka add 2d46024 (chores) camel-kafka: rework the commit management add d65d574 (chores) camel-kafka: simplify and abstract the creation of custom commit factories add 66497dd (chores) camel-kafka: minor documentation fix add f23b5f715 camel-google-mail: Ensure google-oauth-client is aligned with the other google-api-client dependencies No new revisions were added by this update. Summary of changes: .../org/apache/camel/catalog/components/kafka.json | 4 +- components/camel-google/camel-google-mail/pom.xml | 9 ++ .../component/kafka/KafkaComponentConfigurer.java | 4 +- .../component/kafka/KafkaEndpointConfigurer.java | 4 +- .../org/apache/camel/component/kafka/kafka.json | 4 +- .../camel-kafka/src/main/docs/kafka-component.adoc | 2 +- .../camel/component/kafka/KafkaComponent.java | 3 + .../camel/component/kafka/KafkaConfiguration.java | 1 + .../camel/component/kafka/KafkaEndpoint.java | 2 + .../camel/component/kafka/KafkaFetchRecords.java | 38 ++---- .../kafka/consumer/AbstractCommitManager.java | 92 +++++++++++++++ .../kafka/consumer/AsyncCommitManager.java | 88 ++++++++++++++ .../CommitManager.java} | 34 +++--- .../component/kafka/consumer/CommitManagers.java | 53 +++++++++ .../kafka/consumer/CommitToOffsetManager.java | 80 +++++++++++++ .../DefaultKafkaManualAsyncCommit.java | 25 ++-- .../DefaultKafkaManualAsyncCommitFactory.java | 19 ++- .../{ => consumer}/DefaultKafkaManualCommit.java | 63 ++++++---- .../DefaultKafkaManualCommitFactory.java | 18 ++- .../DefaultKafkaManualSyncCommit.java | 18 ++- .../{ => consumer}/KafkaAsyncManualCommit.java | 2 +- .../kafka/{ => consumer}/KafkaManualCommit.java | 2 +- .../kafka/consumer/KafkaManualCommitFactory.java | 82 +++++++++++++ .../kafka/consumer/NoopCommitManager.java | 52 ++++++++ .../kafka/consumer/SyncCommitManager.java | 71 +++++++++++ .../consumer/support/KafkaRecordProcessor.java | 131 ++------------------- .../support/KafkaRecordProcessorFacade.java | 20 ++-- .../support/PartitionAssignmentListener.java | 12 +- .../kafka/consumer/support/ProcessingResult.java | 4 +- .../KafkaConsumerAsyncManualCommitIT.java | 6 +- .../integration/KafkaConsumerManualCommitIT.java | 2 +- .../ROOT/pages/camel-3x-upgrade-guide-3_15.adoc | 15 +++ .../dsl/KafkaComponentBuilderFactory.java | 6 +- .../endpoint/dsl/KafkaEndpointBuilderFactory.java | 6 +- 34 files changed, 710 insertions(+), 262 deletions(-) create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AbstractCommitManager.java create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AsyncCommitManager.java rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{KafkaManualCommitFactory.java => consumer/CommitManager.java} (57%) create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitManagers.java create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitToOffsetManager.java rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{ => consumer}/DefaultKafkaManualAsyncCommit.java (69%) rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{ => consumer}/DefaultKafkaManualAsyncCommitFactory.java (64%) rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{ => consumer}/DefaultKafkaManualCommit.java (52%) rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{ => consumer}/DefaultKafkaManualCommitFactory.java (64%) rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{ => consumer}/DefaultKafkaManualSyncCommit.java (71%) rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{ => consumer}/KafkaAsyncManualCommit.java (95%) rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{ => consumer}/KafkaManualCommit.java (95%) create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/KafkaManualCommitFactory.java create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/NoopCommitManager.java create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/SyncCommitManager.java