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.
