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 <anco...@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")
