This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch topicMustExists
in repository https://gitbox.apache.org/repos/asf/camel.git
from 32907573de6 CAMEL-21774: camel-kafka - Add topicMustExists option so
consumer can fail if broker has no topic
add 8ce48a00d72 CAMEL-21774: camel-kafka - Add topicMustExists option so
consumer can fail if broker has no topic
No new revisions were added by this update.
Summary of changes:
.../org/apache/camel/catalog/components/kafka.json | 159 ++++++++++-----------
.../component/kafka/KafkaComponentConfigurer.java | 12 +-
.../component/kafka/KafkaEndpointConfigurer.java | 6 -
.../component/kafka/KafkaEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/kafka/kafka.json | 159 ++++++++++-----------
.../camel/component/kafka/KafkaComponent.java | 19 +++
.../camel/component/kafka/KafkaConfiguration.java | 19 ---
.../camel/component/kafka/KafkaFetchRecords.java | 2 +-
.../dsl/KafkaComponentBuilderFactory.java | 25 ++++
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 46 ------
10 files changed, 210 insertions(+), 240 deletions(-)
