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 4a48e09 Regen for commit 6b846b40a563d40d3e89184cd768dceffe326d3d
add 473e283 CAMEL-17813: camel-kafka - Better WARN message when error
creating/initializing kafka consumer
add e606be0 CAMEL-17183: camel-kafka - Enrich health check with last
error if failing to create/initialize kafka consumer, to have more visibility
add 521b191 camel-jbang - Show more details in health check error-message
add 2daea0e CAMEL-17813: camel-kafka - Add options on component level to
configure backoff for recover of the consumer attempting to create kafka
consumer and afterwards subscribe to kafka broker. We need 2 steps as former is
more fatal (eg invalid configuration) vs latter that can be a network glitch to
the actual kafka brokers.
No new revisions were added by this update.
Summary of changes:
.../org/apache/camel/catalog/components/kafka.json | 4 +
.../component/kafka/KafkaComponentConfigurer.java | 24 ++++
.../org/apache/camel/component/kafka/kafka.json | 4 +
.../camel/component/kafka/KafkaComponent.java | 69 +++++++++++
.../camel/component/kafka/KafkaConsumer.java | 16 +--
.../kafka/KafkaConsumerFatalException.java} | 17 +--
.../component/kafka/KafkaConsumerHealthCheck.java | 14 ++-
.../camel/component/kafka/KafkaFetchRecords.java | 132 ++++++++++++++++++---
.../apache/camel/support/task/ForegroundTask.java | 19 ++-
.../task/budget/IterationBoundedBudgetBuilder.java | 18 ++-
.../budget/IterationTimeBoundedBudgetBuilder.java | 16 ++-
.../dsl/KafkaComponentBuilderFactory.java | 87 ++++++++++++++
.../org/apache/camel/main/VertxHttpServer.java | 36 +++++-
13 files changed, 410 insertions(+), 46 deletions(-)
copy
components/{camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/api/XmlSignatureFormatException.java
=>
camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumerFatalException.java}
(61%)
