You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2022/03/17 17:38:21 UTC
[camel] branch main updated (4a48e09 -> 2daea0e)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch main
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%)