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/03/01 19:23:35 UTC
[camel] branch regen_bot updated (a118f6e -> 33e6f2b)
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 a118f6e CAMEL-17684 - Support ability to load properties from Vault/Secrets cloud services - GCP Secrets Manager
add 83d3697 CAMEL-15562: added a reusable kafka strategy
add 9aab52d CAMEL-15562: preliminary implementation of the user-facing resume API
add 0992cbc CAMEL-15562: cleanup the creation of the strategy factories
add 5547505 CAMEL-15562: removed the resume strategy option from components
add 4e1bd78 CAMEL-15562: fixed not starting strategies instances
add 63fc1e0 CAMEL-15562: further simplification of the API
add 6a55b31 CAMEL-15562: abstract the underlying cache so it's configurable
add e08ec3b CAMEL-15562: offset should skip when converting to InputStream
add ece9df5 CAMEL-17117: preliminary documentation for the resume strategy
add 3a56bea CAMEL-15562: fixed resumables availability check
add 616b50d CAMEL-15562: minor cleanups for the Kafka strategy
add de8389c CAMEL-155623: implement getters on the ResumeAware
add 1e76dd6 CAMEL-15562: use the service interface to avoid overlap in life cycle management
add bbd4a84 CAMEL-15562: simplify defining and setting the resume strategy
add 519f6ab CAMEL-15562: minor adjustments to the resume API log messages
add cfe69f6 CAMEL-15562: simplify the resumable processor lifecycle
add 33e6f2b Regen for commit cfe69f612a76f6ae9222209c045eed940fd276c1
No new revisions were added by this update.
Summary of changes:
.../camel/catalog/components/aws2-kinesis.json | 2 -
.../apache/camel/catalog/components/couchdb.json | 1 -
.../org/apache/camel/catalog/components/file.json | 1 -
.../org/apache/camel/catalog/components/kafka.json | 2 -
.../apache/camel/catalog/schemas/camel-spring.xsd | 9 +
.../aws2/kinesis/Kinesis2ComponentConfigurer.java | 6 -
.../aws2/kinesis/Kinesis2EndpointConfigurer.java | 6 -
.../aws2/kinesis/Kinesis2EndpointUriFactory.java | 3 +-
.../camel/component/aws2/kinesis/aws2-kinesis.json | 2 -
.../aws2/kinesis/Kinesis2Configuration.java | 14 -
.../component/aws2/kinesis/Kinesis2Consumer.java | 7 +-
.../kinesis/consumer/KinesisResumeStrategy.java | 12 +-
.../couchdb/CouchDbEndpointConfigurer.java | 6 -
.../couchdb/CouchDbEndpointUriFactory.java | 3 +-
.../apache/camel/component/couchdb/couchdb.json | 1 -
.../component/couchdb/CouchDbChangesetTracker.java | 4 +-
.../camel/component/couchdb/CouchDbConsumer.java | 15 +-
.../camel/component/couchdb/CouchDbEndpoint.java | 15 -
.../couchdb/consumer/CouchDbResumeStrategy.java | 12 +-
...tory.java => CouchDbResumeStrategyFactory.java} | 10 +-
.../component/file/FileEndpointConfigurer.java | 6 -
.../component/file/FileEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/file/file.json | 1 -
.../apache/camel/component/file/FileConsumer.java | 24 +-
.../apache/camel/component/file/FileEndpoint.java | 20 --
.../camel/component/file/GenericFileConverter.java | 5 +-
.../component/file/consumer/FileResumeSet.java | 8 +-
.../component/kafka/KafkaComponentConfigurer.java | 6 -
.../component/kafka/KafkaEndpointConfigurer.java | 6 -
.../component/kafka/KafkaEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/kafka/kafka.json | 2 -
.../camel/component/kafka/KafkaConfiguration.java | 24 --
.../camel/component/kafka/KafkaConsumer.java | 15 +-
.../camel/component/kafka/KafkaFetchRecords.java | 10 +-
.../support/KafkaConsumerResumeStrategy.java | 12 +-
.../support/PartitionAssignmentListener.java | 13 +-
.../consumer/support/ResumeStrategyFactory.java | 13 +-
.../resume/kafka/AbstractKafkaResumeStrategy.java | 320 +++++++++++++++++++++
.../KafkaConsumerWithResumeRouteStrategyIT.java | 233 +++++++++++++++
.../KafkaConsumerWithResumeStrategyIT.java | 118 --------
.../src/test/resources/log4j2.properties | 5 +-
.../org/apache/camel/ExchangeConstantProvider.java | 3 +-
.../src/main/java/org/apache/camel/Exchange.java | 1 +
.../{ResumeStrategy.java => ResumeAware.java} | 18 +-
.../{ResumeStrategy.java => ResumeCache.java} | 34 ++-
.../main/java/org/apache/camel/ResumeStrategy.java | 2 +-
.../src/main/java/org/apache/camel/Route.java | 5 +
.../org/apache/camel/impl/engine/DefaultRoute.java | 11 +
.../docs/modules/eips/pages/resume-strategies.adoc | 179 ++++++++++++
.../apache/camel/model/ProcessorDefinition.java | 23 ++
.../apache/camel/model/ResumableDefinition.java | 66 +++++
.../camel/processor/resume/NoOffsetException.java} | 25 +-
.../processor/resume/ResumableCompletion.java | 61 ++++
.../camel/processor/resume/ResumableProcessor.java | 155 ++++++++++
.../org/apache/camel/reifier/ProcessorReifier.java | 3 +
.../org/apache/camel/reifier/ResumableReifier.java | 54 ++++
.../FileConsumerResumeFromOffsetStrategyTest.java | 48 +++-
.../file/FileConsumerResumeStrategyTest.java | 45 ++-
.../dsl/Aws2KinesisComponentBuilderFactory.java | 19 --
.../dsl/KafkaComponentBuilderFactory.java | 25 --
.../dsl/CouchDbEndpointBuilderFactory.java | 36 ---
.../endpoint/dsl/FileEndpointBuilderFactory.java | 38 ---
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 48 ----
.../dsl/Kinesis2EndpointBuilderFactory.java | 36 ---
64 files changed, 1389 insertions(+), 524 deletions(-)
rename components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/consumer/{CouchDdResumeStrategyFactory.java => CouchDbResumeStrategyFactory.java} (82%)
create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/AbstractKafkaResumeStrategy.java
create mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java
delete mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeStrategyIT.java
copy core/camel-api/src/main/java/org/apache/camel/{ResumeStrategy.java => ResumeAware.java} (64%)
copy core/camel-api/src/main/java/org/apache/camel/{ResumeStrategy.java => ResumeCache.java} (56%)
create mode 100644 core/camel-core-engine/src/main/docs/modules/eips/pages/resume-strategies.adoc
create mode 100644 core/camel-core-model/src/main/java/org/apache/camel/model/ResumableDefinition.java
copy core/{camel-api/src/main/java/org/apache/camel/ResumeStrategy.java => camel-core-processor/src/main/java/org/apache/camel/processor/resume/NoOffsetException.java} (57%)
create mode 100644 core/camel-core-processor/src/main/java/org/apache/camel/processor/resume/ResumableCompletion.java
create mode 100644 core/camel-core-processor/src/main/java/org/apache/camel/processor/resume/ResumableProcessor.java
create mode 100644 core/camel-core-reifier/src/main/java/org/apache/camel/reifier/ResumableReifier.java