[camel-examples] branch main updated (b7a6b9b -> 71856ec)

[or...@apache.org]

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%)