You need to send something to direct. As it is you're not sending messages
to your route.
Use a timer.
Il giorno mar 31 mar 2020 alle ore 14:18 Sanu Sandesh <
muralisandes...@gmail.com> ha scritto:
> 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
>
