This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
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
new 83d3697 CAMEL-15562: added a reusable kafka strategy
new 9aab52d CAMEL-15562: preliminary implementation of the user-facing
resume API
new 0992cbc CAMEL-15562: cleanup the creation of the strategy factories
new 5547505 CAMEL-15562: removed the resume strategy option from
components
new 4e1bd78 CAMEL-15562: fixed not starting strategies instances
new 63fc1e0 CAMEL-15562: further simplification of the API
new 6a55b31 CAMEL-15562: abstract the underlying cache so it's
configurable
new e08ec3b CAMEL-15562: offset should skip when converting to InputStream
new ece9df5 CAMEL-17117: preliminary documentation for the resume strategy
new 3a56bea CAMEL-15562: fixed resumables availability check
new 616b50d CAMEL-15562: minor cleanups for the Kafka strategy
new de8389c CAMEL-155623: implement getters on the ResumeAware
new 1e76dd6 CAMEL-15562: use the service interface to avoid overlap in
life cycle management
new bbd4a84 CAMEL-15562: simplify defining and setting the resume strategy
new 519f6ab CAMEL-15562: minor adjustments to the resume API log messages
new cfe69f6 CAMEL-15562: simplify the resumable processor lifecycle
The 16 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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 | 101 +++++++
.../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, 1481 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
