I believe the connection string format is "host1:port1,host2:port2,host3:port3..." (storm-kafka uses Curator under the hood), so just supply multiple Zookeeper server urls to the ZkHosts constructor.
2018-02-21 16:18 GMT+01:00 praveen puskar <puskar.prav...@gmail.com>: > > Hi, > > I have 2 topologies which processes live streams from more then 500 > applications. It was working with one zookeeper from the Zookeeper Quorum. > As the API don;t provide(not i know of) support for KafkaSpout > configuration. Intent here is to be highly available. > > > Find below the details : > > To configure a kafkaSpout, it Takes BrokerHosts which in turn take one > zookeeper host. > > BrokerHosts host = new ZkHosts("zookeeper-server-1:2181"); > SpoutConfig spoutConfig = new SpoutConfig(host, > TopologyConstants.KAFKA_QUEUE.SOURCE, > "/" + TopologyConstants.KAFKA_QUEUE.SOURCE, ID); > KafkaSpout kafkaSpout = new KafkaSpout(spoutConfig); > > Problem is, If i have a zookeeper quorum(cluster of 3 zk servers), how do > i configure KafkaSpoutto take all the members of quorum instead of only > 1. As one zookeeper server may get down and the whole topology will be > unavailable. > > > > -- > Regards > Praveen Puskar > > > > > > Please save TREE. Save the Environment. Make a contribution in retarding > Global Warming. > > Please do not print this email unless it is absolutely necessary. >