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:31:46 UTC
[camel] branch regen_bot updated (66497dd -> dc1c250)
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.
omit 66497dd (chores) camel-kafka: minor documentation fix
omit d65d574 (chores) camel-kafka: simplify and abstract the creation of custom commit factories
omit 2d46024 (chores) camel-kafka: rework the commit management
omit 9bdbf7b CAMEL-15562: created a commit manager in camel-kafka
omit cc68891 CAMEL-15562: reorganize code to simplify providing out-of-the-box resume strategies
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/regen_bot (dc1c250)
\
O -- O -- O (66497dd)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../org/apache/camel/catalog/components/kafka.json | 4 +-
.../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 +-
.../DefaultKafkaManualAsyncCommit.java | 25 ++--
.../DefaultKafkaManualAsyncCommitFactory.java | 19 +--
.../{consumer => }/DefaultKafkaManualCommit.java | 63 ++++------
.../DefaultKafkaManualCommitFactory.java | 18 +--
.../DefaultKafkaManualSyncCommit.java | 18 +--
.../{consumer => }/KafkaAsyncManualCommit.java | 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 => }/KafkaManualCommit.java | 2 +-
...tManager.java => KafkaManualCommitFactory.java} | 34 +++---
.../kafka/consumer/AbstractCommitManager.java | 92 ---------------
.../kafka/consumer/AsyncCommitManager.java | 88 --------------
.../component/kafka/consumer/CommitManagers.java | 53 ---------
.../kafka/consumer/CommitToOffsetManager.java | 80 -------------
.../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 +-
33 files changed, 262 insertions(+), 701 deletions(-)
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%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{consumer/CommitManager.java => KafkaManualCommitFactory.java} (57%)
delete mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AbstractCommitManager.java
delete mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AsyncCommitManager.java
delete mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitManagers.java
delete mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitToOffsetManager.java
delete mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/KafkaManualCommitFactory.java
delete mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/NoopCommitManager.java
delete mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/SyncCommitManager.java