The zookeeper is running in port 2181. The kafka broker is running in port
9092.
On Sun, Jan 25, 2015 at 3:21 PM, Margus Roo wrote:
> is there any zookeepers running in your localhost in 9092 port?
>
> Margus (margusja) Roohttp://margus.roo.ee
> skype: margusja
> +372 51 480
>
> On 25/01/15 23:
is there any zookeepers running in your localhost in 9092 port?
Margus (margusja) Roo
http://margus.roo.ee
skype: margusja
+372 51 480
On 25/01/15 23:14, clay teahouse wrote:
I meant zookeeper is external to storm. I running the zookeeper that
comes with kafka.
On Sun, Jan 25, 2015 at 3:11 PM
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 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
So your storm's zookeeper is external. But how about Kafka's?
Margus (margusja) Roo
http://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 topo
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 z
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) Roo
http://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 sto
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
