I am sure this has probably been answered before somewhere but I can't find
a correct answer.

What is the difference between

*org.apache.storm.kafka.spout.KafkaSpout*

and

*org.apache.storm.kafka.KafkaSpout*

In my experience the first one uses *KafkaSpoutConfig *to connect to broker
directly while the second one connects to Zookeeper and resolves to a
leader broker.

Correct me if I am wrong. Is one of the old way of doing things versus new
way?

If I have very simplistic two brokers connected to one zk and a topic say X
replicated between the two, in the second way, I only have to connect to ZK
but in the first way I have to connect to broker directly.

What if I have two brokers as I mentioned above do I need two storm spouts
then for the case of storm.kafka.KafkaSpout? If that's the case would I
need to set something up to *not *process duplicate messages from two
spouts?

Again if I got something wrong or misunderstanding something please correct
me if I am wrong.

Reply via email to