camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "web_nabble@sunilsamuel.com" <web_nab...@sunilsamuel.com>
Subject Re: Camel Kafka Component as a Consumer within a Route
Date Wed, 23 Dec 2015 14:07:18 GMT
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.

Mime
View raw message