You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/30 07:59:52 UTC
[camel-spring-boot-examples] branch master updated:
Camel-Example-Kafka with Avro: Moved to keySerializer and valueSerializer
Options
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-spring-boot-examples.git
The following commit(s) were added to refs/heads/master by this push:
new b90dc7d Camel-Example-Kafka with Avro: Moved to keySerializer and valueSerializer Options
b90dc7d is described below
commit b90dc7d10b97b62201c8029fc88ca30c175ebbec
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 30 08:59:20 2020 +0100
Camel-Example-Kafka with Avro: Moved to keySerializer and valueSerializer Options
---
.../main/java/org/apache/camel/example/kafka/avro/AvroRouteBuilder.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/camel-example-spring-boot-kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/AvroRouteBuilder.java b/camel-example-spring-boot-kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/AvroRouteBuilder.java
index e1c116a..2bcb476 100644
--- a/camel-example-spring-boot-kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/AvroRouteBuilder.java
+++ b/camel-example-spring-boot-kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/AvroRouteBuilder.java
@@ -26,7 +26,7 @@ public class AvroRouteBuilder extends RouteBuilder {
from("timer://foo?period={{period}}")
.setBody(constant("Hi This is Avro example"))
.process(new KafkaAvroMessageProcessor())
- .to("kafka:{{producer.topic}}?brokers={{kafka.bootstrap.url}}&keySerializerClass=org.apache.kafka.common.serialization.StringSerializer&serializerClass=org.apache.camel.example.kafka.avro.CustomKafkaAvroSerializer");
+ .to("kafka:{{producer.topic}}?brokers={{kafka.bootstrap.url}}&keySerializer=org.apache.kafka.common.serialization.StringSerializer&valueSerializer=org.apache.camel.example.kafka.avro.CustomKafkaAvroSerializer");
from("timer://foo?period={{period}}")
.from("kafka:{{consumer.topic}}?brokers={{kafka.bootstrap.url}}&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&valueDeserializer=org.apache.camel.example.kafka.avro.CustomKafkaAvroDeserializer")