This is an automated email from the ASF dual-hosted git repository.
acosentino 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 7de6e14 Regen for commit a09de9cb2edb95411323e98a23f8e9a939d3c11a
7de6e14 is described below
commit 7de6e1453c0b51dd43500faf64d437909ec9b798
Author: oscerd <osc...@users.noreply.github.com>
AuthorDate: Mon Jan 4 13:48:42 2021 +0000
Regen for commit a09de9cb2edb95411323e98a23f8e9a939d3c11a
Signed-off-by: GitHub <nore...@github.com>
---
camel-dependencies/pom.xml | 4 ++--
.../apache/camel/catalog/docs/kafka-component.adoc | 21 +--------------------
2 files changed, 3 insertions(+), 22 deletions(-)
diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml
index 5d30c35..76ebfe9 100644
--- a/camel-dependencies/pom.xml
+++ b/camel-dependencies/pom.xml
@@ -74,8 +74,8 @@
<aws-java-sdk2-version>2.15.57</aws-java-sdk2-version>
<aws-xray-version>2.6.1</aws-xray-version>
<axiom-version>1.2.14</axiom-version>
-
<azure-eventhubs-checkpointstore-blob-version>1.2.0</azure-eventhubs-checkpointstore-blob-version>
- <azure-eventhubs-java-version>5.2.0</azure-eventhubs-java-version>
+
<azure-eventhubs-checkpointstore-blob-version>1.3.1</azure-eventhubs-checkpointstore-blob-version>
+ <azure-eventhubs-java-version>5.3.1</azure-eventhubs-java-version>
<azure-storage-blob-java-sdk12-version>12.9.0</azure-storage-blob-java-sdk12-version>
<azure-storage-java-sdk-version>8.6.0</azure-storage-java-sdk-version>
<azure-storage-queue-java-sdk12-version>12.7.0</azure-storage-queue-java-sdk12-version>
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 fa17fc0..9543557 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
@@ -378,7 +378,7 @@ camelContext.addRoutes(new RouteBuilder() {
}
});
----
-
+
=== Producing messages to Kafka
@@ -580,22 +580,3 @@ from("kafka:my_topic?headerFilterStrategy=#myStrategy")
`myStrategy` object should be subclass of `HeaderFilterStrategy` and must be
placed in the Camel registry, either manually or by registration as a bean in
Spring/Blueprint, as it is `CamelContext` aware.
include::camel-spring-boot::page$kafka-starter.adoc[]
-
-== Consuming Avro messages from Kafka using the schema-registry
-*Since Camel 3.0.0*
-
-This route applies the schema and converts the Avro messages to POJOs for
further processing:
-
-[source,java]
-----
-from(kafka("avro-events")
- .brokers("localhost:9092")
- .schemaRegistryURL("http://localhost:8081";)
- .specificAvroReader(true)
- .valueDeserializer("io.confluent.kafka.serializers.KafkaAvroDeserializer")
- .log("Avro Message: ${body}")
-----
-
-For this to work, you need to use `avro-maven-plugin` to generate the Java
sources of your POJOs from your schema
-files. Put your `.avsc` files in the `src/main/avro` directory of your project
where the plugin looks for them
-by default.
\ No newline at end of file
