STORM-559: ZkHosts in README should use 2181 as port. Signed-off-by: P. Taylor Goetz <ptgo...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/835a410c Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/835a410c Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/835a410c Branch: refs/heads/0.9.3-branch Commit: 835a410c879dc1eb02d9670410f65fe0be6f28c6 Parents: f0de11a Author: Parth Brahmbhatt <brahmbhatt.pa...@gmail.com> Authored: Wed Jan 14 12:27:35 2015 -0800 Committer: P. Taylor Goetz <ptgo...@gmail.com> Committed: Wed Mar 18 11:09:45 2015 -0400 ---------------------------------------------------------------------- external/storm-kafka/README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/835a410c/external/storm-kafka/README.md ---------------------------------------------------------------------- diff --git a/external/storm-kafka/README.md b/external/storm-kafka/README.md index 02d9767..7442a0e 100644 --- a/external/storm-kafka/README.md +++ b/external/storm-kafka/README.md @@ -18,7 +18,7 @@ Kafka's zookeeper's entries to track brokerHost -> partition mapping. You can in public ZkHosts(String brokerZkStr, String brokerZkPath) public ZkHosts(String brokerZkStr) ``` -Where brokerZkStr is just ip:port e.g. localhost:9092. brokerZkPath is the root directory under which all the topics and +Where brokerZkStr is just ip:port e.g. localhost:2181. brokerZkPath is the root directory under which all the topics and partition information is stored. by Default this is /brokers which is what default kafka implementation uses. By default the broker-partition mapping is refreshed every 60 seconds from zookeeper. If you want to change it you