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 2021/10/05 16:16:59 UTC
[camel] branch regen_bot updated (8681620 -> 58c074d)
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 8681620 Sync deps
add 58c074d CAMEL-17045: refactored Kafka's consumer strategy
No new revisions were added by this update.
Summary of changes:
.../org/apache/camel/catalog/components/kafka.json | 4 ++--
.../component/kafka/KafkaComponentConfigurer.java | 4 ++--
.../component/kafka/KafkaEndpointConfigurer.java | 4 ++--
.../org/apache/camel/component/kafka/kafka.json | 4 ++--
.../camel/component/kafka/KafkaConfiguration.java | 10 +++++-----
...trategy.java => KafkaConsumerResumeStrategy.java} | 3 ++-
...y.java => OffsetKafkaConsumerResumeStrategy.java} | 6 +++---
.../support/PartitionAssignmentListener.java | 2 +-
.../consumer/support/ResumeStrategyFactory.java | 12 ++++++------
...va => SeekPolicyKafkaConsumerResumeStrategy.java} | 6 +++---
...T.java => KafkaConsumerWithResumeStrategyIT.java} | 12 ++++++------
.../{PredicateFactory.java => ResumeStrategy.java} | 16 ++++++++--------
.../component/dsl/KafkaComponentBuilderFactory.java | 14 +++++++-------
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 20 ++++++++++----------
14 files changed, 59 insertions(+), 58 deletions(-)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/{ResumeStrategy.java => KafkaConsumerResumeStrategy.java} (92%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/{OffsetResumeStrategy.java => OffsetKafkaConsumerResumeStrategy.java} (91%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/{SeekPolicyResumeStrategy.java => SeekPolicyKafkaConsumerResumeStrategy.java} (88%)
rename components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/{KafkaConsumerWithCustomResumeStrategyIT.java => KafkaConsumerWithResumeStrategyIT.java} (88%)
copy core/camel-api/src/main/java/org/apache/camel/{PredicateFactory.java => ResumeStrategy.java} (67%)