This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 9fc38ef Regen
9fc38ef is described below
commit 9fc38efbd68f1f006e6ffda1d028924289b3cec7
Author: Claus Ibsen <[email protected]>
AuthorDate: Mon Dec 7 18:07:11 2020 +0100
Regen
---
.../modules/ROOT/pages/vertx-kafka-component.adoc | 25 ++++++++++++++--------
1 file changed, 16 insertions(+), 9 deletions(-)
diff --git a/docs/components/modules/ROOT/pages/vertx-kafka-component.adoc
b/docs/components/modules/ROOT/pages/vertx-kafka-component.adoc
index d30418e..6ad36ee 100644
--- a/docs/components/modules/ROOT/pages/vertx-kafka-component.adoc
+++ b/docs/components/modules/ROOT/pages/vertx-kafka-component.adoc
@@ -44,7 +44,7 @@ Almost all the Kafka configuration for the component are
*auto generated* from K
== URI format
-[source,java]
+[source,text]
---------------------------
vertx-kafka:topic[?options]
---------------------------
@@ -369,7 +369,9 @@ Following header value types are supported when producing
the message *from* cam
Note: all headers propagated *from* kafka *to* camel exchange will contain
`io.vertx.core.buffer.Buffer` value by default.
Having the support of `io.vertx.core.buffer.Buffer` header type, will allow
you un-wrap the header to any type without much knowledge in `byte[]`. For
example:
-```
+
+[source,java]
+----
from("direct")
.process(exchange -> {
// set kafka header
@@ -377,9 +379,11 @@ from("direct")
exchange.getIn().setBody("test event");
})
.to("vertx-kafka:test_topic?bootstrapServers=kafka9092")
-```
+----
Then later:
-```
+
+[source,java]
+----
from("vertx-kafka:test_topic?bootstrapServers=kafka9092")
.process(exchange -> {
// get our kafka header
@@ -387,7 +391,7 @@ from("vertx-kafka:test_topic?bootstrapServers=kafka9092")
System.out.println(headerBuffer.getDouble(0); // it will print 2.0
})
.to("direct)
-```
+----
By default all headers are being filtered by `KafkaHeaderFilterStrategy`.
Strategy filters out headers which start with `Camel` or `org.apache.camel`
prefixes.
@@ -421,7 +425,8 @@
from("vertx-kafka:test1,test2?bootstrapServers=localhost:9092")
Here is the minimal route you need in order to write messages to Kafka.
-```
+[source,java]
+----
from("direct")
.process(exchange -> {
// set kafka header
@@ -432,10 +437,12 @@ from("direct")
exchange.getIn().setBody("test event");
})
.to("vertx-kafka:test_topic?bootstrapServers=kafka9092")
-```
+----
Also, the component supports as well *aggregation* of messages by sending
events as *iterable* of either Exchanges/Messages or normal data (e.g: list of
Strings). For example:
-```
+
+[source,java]
+----
from("direct:start")
.process(exchange -> {
final List<String> messages = new LinkedList<>();
@@ -447,7 +454,7 @@ from("direct:start")
exchange.getIn().setBody(messages);
})
.to("vertx-kafka:test_topic?bootstrapServers=kafka9092")
-```
+----
include::camel-spring-boot::page$vertx-kafka-starter.adoc[]
