Team,
I am trying to integrate Camel with Kafka. Written simple application with
camelcontext initialized in main() program & added my routebuilder with
below code:
from("direct:start")
.setBody(constant("Message from Camel")) // Message to send
.setHeader(KafkaConstants.KEY, constant("Camel")) // Key of
the message
.to("kafka:test?brokers=localhost:2181");
where my topic is : test
This code not sending message to my kafka consumer. where as plain kafka
code is sending. I am trying to see consumer using CLI.
Need assistance pls.
REgards,
Sandesh
