local:
[zk: localhost:2000(CONNECTED) 9] get
/brokers/rawWarehousePriceSpout/partition_0
0
cZxid = 0x42
ctime = Thu May 21 19:25:26 BST 2015
mZxid = 0x42
mtime = Thu May 21 19:25:26 BST 2015
pZxid = 0x42
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 1
numChildren = 0
[zk: localhost:2000(CONNECTED) 10]
So the zookeeper hosts I passed in was the remote instance that kafka is
connected to, so this config
ZkHosts zkhost = new ZkHosts(zookeeperQuorum,"/brokers"); // /brokers -> kafka
broker
SpoutConfig spoutconfig = new SpoutConfig(zkhost, topic,
"/brokers", spoutId);
Is
zookeeperQuorum = 1.1.1.1:2181 not localhost
> On 21 May 2015, at 19:28, Cristian Makoto Sandiga <[email protected]> wrote:
>
> get /brokers/rawWarehousePriceSpout/partition_0
