Hi i am using camel 2.15.1 creating a camel bundle to connect kafka cluster
the route i am writing is
<route id="camel-kafka-producer">
<from uri="timer://foo?period=5000" />
<process ref="messageGenerator" />
<log message="Message Generated Sending to Kafka" />
<to
uri="kafka:host1:9092,host2:9094,host3:9093?zookeeperHost=host1&zookeeperPort=2181&topic=mytopic.out&groupId=group1&serializerClass=kafka.serializer.StringEncoder&keySerializerClass=kafka.serializer.StringEncoder"
/>
<log message="Message Sent Successfully" />
</route>
But this is static kafka discovery i want to do zookeeper based discovery in
which i dont have to configure all the kafka server to the route uri... Plz
need your help
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Kafka-zookeeper-based-discovery-tp5783546.html
Sent from the Camel - Users mailing list archive at Nabble.com.