Interesting my kafka did not create that it just did /brokers
[zk: 127.0.0.1:2181(CONNECTED) 5] ls /
[hbase, zookeeper, admin, consumers, config, hive_zookeeper_namespace_hive,
controller, storm, brokers, controller_epoch]
[zk: 127.0.0.1:2181(CONNECTED) 6] ls /brokers
[rawWarehousePriceSpout, topics, ids]
[zk: 127.0.0.1:2181(CONNECTED) 7] ls /kafka
Node does not exist: /kafka
[zk: 127.0.0.1:2181(CONNECTED) 8]
So what should one have in the spout config?
ZkHosts zkhost = new ZkHosts(brokerHosts,"/brokers"); // /brokers -> kafka
broker
SpoutConfig spoutconfig = new SpoutConfig(zkhost, topic,
"/brokers", spoutId);
> On 24 May 2015, at 10:47, Binh Nguyen Van <[email protected]> wrote:
>
> /kafka
