This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch camel-3.18.x
in repository https://gitbox.apache.org/repos/asf/camel.git
from 98c46d8061c CAMEL-18371: do load the cache when resuming with the file
component
new 9e832b0428c CAMEL-18356: consolidated the Kafka resume strategies
new b4c8000991b (chores) camel-kafka: fixed typo in the resume strategy
new 8bf4ae69846 (chores) camel-kafka: add log guard on resume strategy
critical path
new fe095bc545b CAMEL-18362: rework the consumer/producer
new 28e1abba16c (chores) camel-kafka: ensure tests run a little bit faster
new 5fedf91e806 CAMEL-18362: wait for the initial cache loading
The 6 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:
.../kafka/KafkaResumeStrategyConfiguration.java | 23 +++
.../KafkaResumeStrategyConfigurationBuilder.java | 17 ++
.../resume/kafka/MultiNodeKafkaResumeStrategy.java | 75 +------
.../kafka/SingleNodeKafkaResumeStrategy.java | 229 ++++++++++++---------
.../KafkaConsumerAsyncManualCommitIT.java | 2 +-
.../KafkaConsumerBadPortHealthCheckIT.java | 2 +-
...fkaConsumerBadPortSupervisingHealthCheckIT.java | 2 +-
.../kafka/integration/KafkaConsumerFullIT.java | 2 +-
.../integration/KafkaConsumerHealthCheckIT.java | 2 +-
.../integration/KafkaConsumerIdempotentIT.java | 2 +-
...kaConsumerIdempotentWithCustomSerializerIT.java | 2 +-
.../KafkaConsumerIdempotentWithProcessorIT.java | 2 +-
.../integration/KafkaConsumerTopicIsPatternIT.java | 5 +-
.../KafkaConsumerUnresolvableHealthCheckIT.java | 2 +-
.../commit/KafkaConsumerNoopCommitIT.java | 2 +-
.../commit/KafkaConsumerSyncCommitIT.java | 2 +-
.../KafkaPausableConsumerCircuitBreakerIT.java | 2 +-
.../integration/pause/KafkaPausableConsumerIT.java | 2 +-
18 files changed, 191 insertions(+), 184 deletions(-)
