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")