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 cb98d84 CAMEL-16849 - Add at least one example for component in docs
- Camel-AWS2-Lambda
add ffcb39f CAMEL-16861: Cleanup and update EIP docs
add b86c255 CAMEL-16949: rework the KafkaFetchRecords to avoid the sleep
add 75768eb CAMEL-16949: re-enable a few tests that were disabled for a
long time
add dffa627 CAMEL-16861: Cleanup and update EIP docs
add bf7a718 xref fix
add be2d9da CAMEL-16861: Cleanup and update EIP docs
add ff720e6 Regen for commit be2d9da7ae40369855f1faa201f6b01b6de827b9
No new revisions were added by this update.
Summary of changes:
.../org/apache/camel/catalog/components/kafka.json | 6 +-
.../org/apache/camel/catalog/models/aggregate.json | 4 +-
.../apache/camel/catalog/schemas/camel-spring.xsd | 4 +-
.../component/kafka/KafkaComponentConfigurer.java | 6 +
.../component/kafka/KafkaEndpointConfigurer.java | 6 +
.../component/kafka/KafkaEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/kafka/kafka.json | 6 +-
.../camel-kafka/src/main/docs/kafka-component.adoc | 10 +-
.../component/kafka/DefaultKafkaManualCommit.java | 11 +-
.../kafka/DefaultKafkaManualCommitFactory.java | 5 +-
.../camel/component/kafka/KafkaConfiguration.java | 17 +-
.../camel/component/kafka/KafkaConsumer.java | 13 +-
.../camel/component/kafka/KafkaFetchRecords.java | 730 ++++++------
.../component/kafka/KafkaManualCommitFactory.java | 2 +-
.../consumer/support/KafkaRecordProcessor.java | 243 ++++
.../consumer/support/OffsetResumeStrategy.java | 62 +
.../support/PartitionAssignmentListener.java | 106 ++
.../support/ResumeStrategy.java} | 19 +-
.../support/ResumeStrategyFactory.java} | 40 +-
.../consumer/support/SeekPolicyResumeStrategy.java | 56 +
.../kafka/integration/KafkaConsumerFullIT.java | 3 -
.../integration/KafkaConsumerManualCommitIT.java | 8 +-
.../sql/stored/template/generated/SSPTParser.java | 833 +++++++------
.../template/generated/SSPTParserConstants.java | 110 +-
.../template/generated/SSPTParserTokenManager.java | 1222 ++++++++++----------
.../dsl/KafkaComponentBuilderFactory.java | 20 +-
.../docs/modules/eips/pages/aggregate-eip.adoc | 497 ++++----
.../docs/modules/eips/pages/batch-config-eip.adoc | 2 +-
.../src/main/docs/modules/eips/pages/bean-eip.adoc | 95 +-
.../modules/eips/pages/change-data-capture.adoc | 4 +-
.../docs/modules/eips/pages/channel-adapter.adoc | 3 +-
.../org/apache/camel/model/aggregate.json | 4 +-
.../apache/camel/model/AggregateDefinition.java | 10 +-
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 47 +-
34 files changed, 2371 insertions(+), 1836 deletions(-)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessor.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/OffsetResumeStrategy.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/PartitionAssignmentListener.java
copy
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{KafkaManualCommitFactory.java
=> consumer/support/ResumeStrategy.java} (56%)
copy
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{KafkaManualCommitFactory.java
=> consumer/support/ResumeStrategyFactory.java} (50%)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/SeekPolicyResumeStrategy.java
