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 9681e03912d camel-jbang - Run should merge --deps with existing
dependencies that may be specified in application.properties
add 59046fe140f CAMEL-18688: add full resume support for Kafka
No new revisions were added by this update.
Summary of changes:
.../org/apache/camel/kafka-adapter-factory | 2 +
.../camel/component/kafka/KafkaConsumer.java | 5 +
.../camel/component/kafka/KafkaFetchRecords.java | 19 +-
.../consumer/support/ResumeStrategyFactory.java | 92 --------
.../support/classic/AssignmentAdapterHelper.java | 49 +++++
.../ClassicRebalanceListener.java} | 31 +--
.../classic/NoOpPartitionAssignmentAdapter.java | 38 ++++
.../OffsetPartitionAssignmentAdapter.java} | 16 +-
.../PartitionAssignmentAdapter.java} | 13 +-
.../SeekPolicyPartitionAssignmentAdapter.java} | 15 +-
.../consumer/support/resume/KafkaResumable.java | 62 ++++++
.../support/resume/KafkaResumeAdapter.java | 113 ++++++++++
.../ResumeRebalanceListener.java} | 32 ++-
.../kafka/SingleNodeKafkaResumeStrategy.java | 5 +-
...KafkaConsumerAutoInstResumeRouteStrategyIT.java | 113 ++++++++++
.../KafkaConsumerWithResumeRouteStrategyIT.java | 239 ---------------------
.../processor/resume/TransientResumeStrategy.java | 113 +++++-----
17 files changed, 493 insertions(+), 464 deletions(-)
create mode 100644
components/camel-kafka/src/generated/resources/META-INF/services/org/apache/camel/kafka-adapter-factory
delete mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ResumeStrategyFactory.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/classic/AssignmentAdapterHelper.java
copy
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/{PartitionAssignmentListener.java
=> classic/ClassicRebalanceListener.java} (67%)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/classic/NoOpPartitionAssignmentAdapter.java
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/{OffsetKafkaConsumerResumeAdapter.java
=> classic/OffsetPartitionAssignmentAdapter.java} (86%)
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/{KafkaConsumerResumeAdapter.java
=> classic/PartitionAssignmentAdapter.java} (75%)
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/{SeekPolicyKafkaConsumerResumeAdapter.java
=> classic/SeekPolicyPartitionAssignmentAdapter.java} (81%)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/resume/KafkaResumable.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/resume/KafkaResumeAdapter.java
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/{PartitionAssignmentListener.java
=> resume/ResumeRebalanceListener.java} (67%)
create mode 100644
components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAutoInstResumeRouteStrategyIT.java
delete mode 100644
components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java
