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&amp;zookeeperPort=2181&amp;topic=mytopic.out&amp;groupId=group1&amp;serializerClass=kafka.serializer.StringEncoder&amp;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.

Reply via email to