camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From swgupta <swatigupt...@gmail.com>
Subject Apache Camel Integration with Apache Kafka
Date Thu, 05 Jan 2017 22:49:06 GMT
Hello All,

I am trying to create an Apache Camel Consumer for a topic in Apache Kafka.
I am using Camel 2.17.0 and Kafka 0.10  and JDK 1.7.
I have attached 2 files, KafkaCamelTestConsumer.java and
KafkaCamelTest.java(Producer)
I have created a topic by the name test1 and trying to produce/consume
messages.
I am able to produce messages using KafkaCamelTest.java program in the topic
"test1", but not able to consume messages. Ideally, it should get printed,
but nothing seems to happen. The log says that the route has started but
does not process any message.
KafkaCamelTestConsumer.java
<http://camel.465427.n5.nabble.com/file/n5792216/KafkaCamelTestConsumer.java>  
KafkaCamelTest.java
<http://camel.465427.n5.nabble.com/file/n5792216/KafkaCamelTest.java>  

Any help on this will be greatly appreciated.

Thanks in advance



--
View this message in context: http://camel.465427.n5.nabble.com/Apache-Camel-Integration-with-Apache-Kafka-tp5792216.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message