This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new a43243b Regen for commit 7ef97add9e80005162467beb9b2081ff0e982fd4
(#5822)
a43243b is described below
commit a43243b0d23ed80b7ae859ee33c860a44e8fc513
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Jul 10 11:53:13 2021 +0200
Regen for commit 7ef97add9e80005162467beb9b2081ff0e982fd4 (#5822)
Signed-off-by: GitHub <[email protected]>
Co-authored-by: davsclaus <[email protected]>
---
.../org/apache/camel/catalog/docs/kafka-component.adoc | 14 +++++++++++++-
docs/components/modules/ROOT/pages/kafka-component.adoc | 14 +++++++++++++-
2 files changed, 26 insertions(+), 2 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/kafka-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/kafka-component.adoc
index 940e9b7..92fd0db 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/kafka-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/kafka-component.adoc
@@ -368,7 +368,7 @@ from("kafka:test?brokers=localhost:9092")
.log(" with the key ${headers[kafka.KEY]}")
----
-If you need to consume messages from multiple topics you can use a comma
separated list of topic names
+If you need to consume messages from multiple topics you can use a comma
separated list of topic names.
[source,java]
----
@@ -380,6 +380,18 @@ from("kafka:test,test1,test2?brokers=localhost:9092")
.log(" with the key ${headers[kafka.KEY]}")
----
+It's also possible to subscribe to multiple topics giving a pattern as the
topic name and using the `topicIsPattern` option.
+
+[source,java]
+----
+from("kafka:test*?brokers=localhost:9092&topicIsPattern=true")
+ .log("Message received from Kafka : ${body}")
+ .log(" on the topic ${headers[kafka.TOPIC]}")
+ .log(" on the partition ${headers[kafka.PARTITION]}")
+ .log(" with the offset ${headers[kafka.OFFSET]}")
+ .log(" with the key ${headers[kafka.KEY]}")
+----
+
When consuming messages from Kafka you can use your own offset management and
not delegate this management to Kafka.
In order to keep the offsets the component needs a `StateRepository`
implementation such as `FileStateRepository`.
This bean should be available in the registry.
diff --git a/docs/components/modules/ROOT/pages/kafka-component.adoc
b/docs/components/modules/ROOT/pages/kafka-component.adoc
index 442f61a..aac57c4 100644
--- a/docs/components/modules/ROOT/pages/kafka-component.adoc
+++ b/docs/components/modules/ROOT/pages/kafka-component.adoc
@@ -370,7 +370,7 @@ from("kafka:test?brokers=localhost:9092")
.log(" with the key ${headers[kafka.KEY]}")
----
-If you need to consume messages from multiple topics you can use a comma
separated list of topic names
+If you need to consume messages from multiple topics you can use a comma
separated list of topic names.
[source,java]
----
@@ -382,6 +382,18 @@ from("kafka:test,test1,test2?brokers=localhost:9092")
.log(" with the key ${headers[kafka.KEY]}")
----
+It's also possible to subscribe to multiple topics giving a pattern as the
topic name and using the `topicIsPattern` option.
+
+[source,java]
+----
+from("kafka:test*?brokers=localhost:9092&topicIsPattern=true")
+ .log("Message received from Kafka : ${body}")
+ .log(" on the topic ${headers[kafka.TOPIC]}")
+ .log(" on the partition ${headers[kafka.PARTITION]}")
+ .log(" with the offset ${headers[kafka.OFFSET]}")
+ .log(" with the key ${headers[kafka.KEY]}")
+----
+
When consuming messages from Kafka you can use your own offset management and
not delegate this management to Kafka.
In order to keep the offsets the component needs a `StateRepository`
implementation such as `FileStateRepository`.
This bean should be available in the registry.
