You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2022/01/20 12:35:36 UTC
[camel] branch regen_bot updated (dc1c250 -> f23b5f715)
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