Hi,
I am a little confused about StaticHost, and ZkHosts, ZkPath, and
Partitions Per Host.
Our kafka uses its own zookeeper, and it has 10 partitions. Our storm use
other zookeepers

So If I am using ZkHosts

KafkaConfig.ZkHosts zkHosts = new KafkaConfig.ZkHosts(

  "kafka-zooker1:2181,kafka-zooker1:2181,kafka-zooker1:2181",

  "/brokers");

What /brokers stands for? The path in Kafka zookeeper or Storm zookeeper? I
assume it means in storm zookeeper, right?

If I am using StaticHosts, I need to provide partitions per host, what does
it mean? For our total 10 partitions,  how many partitions I should give to
three host? Will it safely read all the 10 partitions from kafka to avoid
data loss?

Thanks in advance.

Chen

Reply via email to