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-examples.git.
from b7a6b9b CAMEL-17821 - Provide camel-debug in a profile (#84)
add 71856ec Add an example for using the Resume API in clusterized mode
with the master component.
No new revisions were added by this update.
Summary of changes:
examples/resume-api/pom.xml | 3 +-
.../kafka/DefaultConsumerPropertyFactory.java | 11 +-
.../kafka/file}/KafkaFileOffsetResumeStrategy.java | 2 +-
.../kafka/file}/LargeFileRouteBuilder.java | 2 +-
.../strategies/kafka/file}/SingleItemCache.java | 2 +-
.../kafka/fileset}/KafkaFileSetResumeStrategy.java | 10 +-
.../kafka/fileset}/LargeDirectoryRouteBuilder.java | 2 +-
.../strategies/kafka/fileset}/ListBasedCache.java | 2 +-
.../strategies/kafka/fileset}/MultiItemCache.java | 2 +-
.../example/resume/file/offset/main/MainApp.java | 6 +-
.../resume-api-fileset-clusterized/README.md | 55 ++++++++++
.../docker-compose.yaml | 14 ++-
.../pom.xml | 20 +++-
.../src/main/docker/Dockerfile | 0
.../clusterized/main/ClusterizedListener.java | 119 +++++++++++++++++++++
.../resume/fileset/clusterized/main/MainApp.java | 63 +++++++++++
.../ClusterAwareKafkaFileSetResumeStrategy.java | 88 +++++++++++++++
.../ClusterizedLargeDirectoryRouteBuilder.java} | 30 +++---
.../src/main/resources/log4j2.properties | 20 +++-
.../src/main/scripts/run.sh | 14 ++-
.../camel/example/resume/fileset/main/MainApp.java | 6 +-
21 files changed, 431 insertions(+), 40 deletions(-)
rename
examples/resume-api/{resume-api-file-offset/src/main/java/org/apache/camel/example/resume/file/offset/strategies
=>
resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/file}/KafkaFileOffsetResumeStrategy.java
(97%)
rename
examples/resume-api/{resume-api-file-offset/src/main/java/org/apache/camel/example/resume/file/offset/strategies
=>
resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/file}/LargeFileRouteBuilder.java
(98%)
rename
examples/resume-api/{resume-api-file-offset/src/main/java/org/apache/camel/example/resume/file/offset/strategies
=>
resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/file}/SingleItemCache.java
(96%)
rename
examples/resume-api/{resume-api-fileset/src/main/java/org/apache/camel/example/resume/fileset/strategies
=>
resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/fileset}/KafkaFileSetResumeStrategy.java
(93%)
copy
examples/resume-api/{resume-api-fileset/src/main/java/org/apache/camel/example/resume/fileset/strategies
=>
resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/fileset}/LargeDirectoryRouteBuilder.java
(97%)
rename
examples/resume-api/{resume-api-fileset/src/main/java/org/apache/camel/example/resume/fileset/strategies
=>
resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/fileset}/ListBasedCache.java
(94%)
rename
examples/resume-api/{resume-api-fileset/src/main/java/org/apache/camel/example/resume/fileset/strategies
=>
resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/fileset}/MultiItemCache.java
(97%)
create mode 100644 examples/resume-api/resume-api-fileset-clusterized/README.md
copy examples/resume-api/{resume-api-file-offset =>
resume-api-fileset-clusterized}/docker-compose.yaml (87%)
copy examples/resume-api/{resume-api-fileset =>
resume-api-fileset-clusterized}/pom.xml (77%)
copy examples/resume-api/{resume-api-fileset =>
resume-api-fileset-clusterized}/src/main/docker/Dockerfile (100%)
create mode 100644
examples/resume-api/resume-api-fileset-clusterized/src/main/java/org/apache/camel/example/resume/fileset/clusterized/main/ClusterizedListener.java
create mode 100644
examples/resume-api/resume-api-fileset-clusterized/src/main/java/org/apache/camel/example/resume/fileset/clusterized/main/MainApp.java
create mode 100644
examples/resume-api/resume-api-fileset-clusterized/src/main/java/org/apache/camel/example/resume/fileset/clusterized/strategies/ClusterAwareKafkaFileSetResumeStrategy.java
rename
examples/resume-api/{resume-api-fileset/src/main/java/org/apache/camel/example/resume/fileset/strategies/LargeDirectoryRouteBuilder.java
=>
resume-api-fileset-clusterized/src/main/java/org/apache/camel/example/resume/fileset/clusterized/strategies/ClusterizedLargeDirectoryRouteBuilder.java}
(64%)
copy examples/resume-api/{resume-api-file-offset =>
resume-api-fileset-clusterized}/src/main/resources/log4j2.properties (70%)
copy examples/resume-api/{resume-api-fileset =>
resume-api-fileset-clusterized}/src/main/scripts/run.sh (89%)
