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 ff16877 CAMEL-17510: camel-yaml-dsl - Generate json schema in
camelCase
add 5cc4c57 [CAMEL-17391] Update elasticsearch-rest documentation (#6759)
add 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
No new revisions were added by this update.
Summary of changes:
.../catalog/components/elasticsearch-rest.json | 4 +-
.../org/apache/camel/catalog/components/kafka.json | 4 +-
.../elasticsearch/elasticsearch-rest.json | 4 +-
.../main/docs/elasticsearch-rest-component.adoc | 10 ++
.../elasticsearch/ElasticsearchComponent.java | 3 +-
.../elasticsearch/ElasticsearchConfiguration.java | 3 +-
.../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 +++
.../ElasticsearchRestComponentBuilderFactory.java | 4 +-
.../dsl/KafkaComponentBuilderFactory.java | 6 +-
.../dsl/ElasticsearchEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 6 +-
40 files changed, 728 insertions(+), 271 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
