Hello,
Yes. Thank you. We are able to do this with PollEnrich. The following
route is modified:
from("timer://foo?fixedRate=true&period=10000")
.setBody().constant("test")
.setHeader("kafka.OFFSET",constant("smallest"))
.pollEnrich("kafka:192.168.111.54:9092?topic=test&"+
"zookeeperHost=192.168.111.54&zookeeperPort=2181&"+
"groupId=groupBatch",1000)
.log("FROM THE TIMER [${body}]")
;
Thank You,
sunil.
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Kafka-Component-as-a-Consumer-within-a-Route-tp5775404p5775410.html
Sent from the Camel Development mailing list archive at Nabble.com.
