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
commit 24668112a2aeabd81aa52a464877b9dacaeac76f
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Dec 7 17:23:05 2020 +0100
Polished
---
.../src/main/docs/vertx-kafka-component.adoc | 25 ++++++++++++++--------
1 file changed, 16 insertions(+), 9 deletions(-)
diff --git
a/components/camel-vertx-kafka/camel-vertx-kafka-component/src/main/docs/vertx-kafka-component.adoc
b/components/camel-vertx-kafka/camel-vertx-kafka-component/src/main/docs/vertx-kafka-component.adoc
index 4779f54..6d90c0b 100644
---
a/components/camel-vertx-kafka/camel-vertx-kafka-component/src/main/docs/vertx-kafka-component.adoc
+++
b/components/camel-vertx-kafka/camel-vertx-kafka-component/src/main/docs/vertx-kafka-component.adoc
@@ -42,7 +42,7 @@ Almost all the Kafka configuration for the component are
*auto generated* from K
== URI format
-[source,java]
+[source,text]
---------------------------
vertx-kafka:topic[?options]
---------------------------
@@ -367,7 +367,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
@@ -375,9 +377,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
@@ -385,7 +389,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.
@@ -419,7 +423,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
@@ -430,10 +435,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<>();
@@ -445,7 +452,7 @@ from("direct:start")
exchange.getIn().setBody(messages);
})
.to("vertx-kafka:test_topic?bootstrapServers=kafka9092")
-```
+----
include::camel-spring-boot::page$vertx-kafka-starter.adoc[]
