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 2022/03/17 18:22:23 UTC

[camel] branch regen_bot updated (4a48e09 -> 2daea0e)

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%)