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 2021/03/21 17:02:01 UTC
[camel] branch 14980 updated (8100f31 -> c2db6c0)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch 14980
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 8100f31 CAMEL-14980: Regen
add 9d4ee38 CAMEL-14980: camel-kafka - Consumer should only re-connect on retryable exceptions. Other severe exceptions should be propagated.
add 2e7612e CAMEL-14980: camel-kafka - Consumer should only re-connect on retryable exceptions. Other severe exceptions should be propagated.
add c682d69 CAMEL-14980: camel-kafka - Consumer should only re-connect on retryable exceptions. Other severe exceptions should be propagated.
add 48858bc CAMEL-14980: camel-kafka - Consumer should only re-connect on retryable exceptions. Other severe exceptions should be propagated.
add 38b8cdc CAMEL-14980: camel-kafka - Consumer should only re-connect on retryable exceptions. Other severe exceptions should be propagated.
add c2db6c0 CAMEL-14980: camel-kafka - Consumer should only re-connect on retryable exceptions. Other severe exceptions should be propagated.
No new revisions were added by this update.
Summary of changes:
.../apache/camel/catalog/docs/kafka-component.adoc | 31 ++-
.../component/kafka/KafkaComponentConfigurer.java | 20 +-
.../component/kafka/KafkaEndpointConfigurer.java | 6 +
.../component/kafka/KafkaEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/kafka/kafka.json | 4 +-
.../camel-kafka/src/main/docs/kafka-component.adoc | 31 ++-
...tegy.java => DefaultPollExceptionStrategy.java} | 24 +-
.../camel/component/kafka/KafkaComponent.java | 35 ++-
.../camel/component/kafka/KafkaConfiguration.java | 21 ++
.../camel/component/kafka/KafkaConsumer.java | 267 +++++++++++++++------
...ionStrategy.java => PollExceptionStrategy.java} | 16 +-
.../apache/camel/component/kafka/PollOnError.java} | 33 +--
.../dsl/KafkaComponentBuilderFactory.java | 63 +++--
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 62 +++++
.../modules/ROOT/pages/kafka-component.adoc | 31 ++-
15 files changed, 489 insertions(+), 158 deletions(-)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{DefaultKafkaConsumerReconnectExceptionStrategy.java => DefaultPollExceptionStrategy.java} (62%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{KafkaConsumerReconnectExceptionStrategy.java => PollExceptionStrategy.java} (65%)
copy components/{camel-avro-rpc/src/main/java/org/apache/camel/component/avro/AvroComponentException.java => camel-kafka/src/main/java/org/apache/camel/component/kafka/PollOnError.java} (61%)