I meant zookeeper is external to storm. I running the zookeeper that comes with kafka.
On Sun, Jan 25, 2015 at 3:11 PM, Margus Roo <[email protected]> wrote: > So your storm's zookeeper is external. But how about Kafka's? > > Margus (margusja) Roohttp://margus.roo.ee > skype: margusja > +372 51 480 > > On 25/01/15 23:08, clay teahouse wrote: > > Thanks Margus. > 1) I don't do anything (at least explicitly) with zookeeper settings or > the offsets. All I do in the topology, I specify the address of the > zookeeper (ZkHosts). Here is some the lines in between: > 2015-01-25T13:26:52.288-0600 s.k.PartitionManager [INFO] Read last > commit offset from zookeeper: 7; old topology_id: > a001b24c-d99c-49f1-8b60-573aac41937e - new topology_id: > ad09f254-ca58-4298-8f57-09741389da56 > 2015-01-25T13:26:52.288-0600 s.k.PartitionManager [INFO] Starting Kafka > localhost:1 from offset 7 > 2015-01-25T13:26:52.297-0600 s.k.PartitionManager [INFO] Read partition > information from: /storm/partition_0 --> null > 2015-01-25T13:26:52.302-0600 s.k.PartitionManager [INFO] No partition > information found, using configuration to determine offset > > 2) So /storm actually is an absolute path? > > On Sun, Jan 25, 2015 at 2:45 PM, Margus Roo <[email protected]> wrote: > >> Maybe you overwrote it in your topology code? >> zk path in example /storm is a place where storm keeps statuses about >> storm in example. >> >> Margus (margusja) Roohttp://margus.roo.ee >> skype: margusja >> +372 51 480 >> >> On 25/01/15 22:16, clay teahouse wrote: >> >> Hi All, >> >> A couple of questions: >> 1) >> What does storm.zookeeper.root point to? The definition says storm root >> directory location. The default value is /storm. But I am not sure I >> understand what this means. If I have external zookeeper running, what >> should this configuration point to? >> >> 2) I am running my topology in cluster mode, and I said with external >> zookeeper (its configuration is specified in storm.yaml). But I am seeing >> the following lines in my worker logs: >> >> s.k.DynamicBrokersReader [INFO] Read partition info from zookeeper: >> GlobalPartitionInformation{partitionMap={0=localhost:9092, >> 1=localhost:9092}} >> .. >> .. >> .. >> s.k.PartitionManager [INFO] No partition information found, using >> configuration to determine offset >> >> I've read that the second message means that storm is not using the >> external zookeeper. If that is the case, what would be the reason for that. >> thanks, >> Clay >> >> >> > >
