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.
>

Reply via email to