[camel-spring-boot-examples] branch main updated: Update AvroRouteBuilder.java (#51)

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot-examples.git


The following commit(s) were added to refs/heads/main by this push:
     new 0c964fe  Update AvroRouteBuilder.java (#51)
0c964fe is described below

commit 0c964fe6152239f9aed7cd84b25830e172707719
Author: Eray Erdem <42184225+erayer...@users.noreply.github.com>
AuthorDate: Fri Feb 18 00:27:12 2022 +0300

    Update AvroRouteBuilder.java (#51)
    
    Only one input is allowed per route.
---
 .../java/org/apache/camel/example/kafka/avro/AvroRouteBuilder.java     | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/AvroRouteBuilder.java
 
b/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/AvroRouteBuilder.java
index 2bcb476..05b34c5 100644
--- 
a/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/AvroRouteBuilder.java
+++ 
b/kafka-avro/src/main/java/org/apache/camel/example/kafka/avro/AvroRouteBuilder.java
@@ -28,8 +28,7 @@ public class AvroRouteBuilder extends RouteBuilder {
         .process(new KafkaAvroMessageProcessor())
             
.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")
+        
from("kafka:{{consumer.topic}}?brokers={{kafka.bootstrap.url}}&keyDeserializer=org.apache.kafka.common.serialization.StringDeserializer&valueDeserializer=org.apache.camel.example.kafka.avro.CustomKafkaAvroDeserializer")
          .process(new KafkaAvroMessageConsumerProcessor())
             .log("${body}");
     }