You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/11/12 17:45:15 UTC
[14/47] storm git commit: Update README.md
Update README.md
minor typos that tripped me up today!
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/573003b4
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/573003b4
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/573003b4
Branch: refs/heads/security
Commit: 573003b45986cce417dccee46f7771b29a6bc337
Parents: cfe7e63
Author: Luke Demi <ld...@gmail.com>
Authored: Mon Oct 13 22:23:33 2014 -0400
Committer: Luke Demi <ld...@gmail.com>
Committed: Mon Oct 13 22:23:33 2014 -0400
----------------------------------------------------------------------
external/storm-kafka/README.md | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/573003b4/external/storm-kafka/README.md
----------------------------------------------------------------------
diff --git a/external/storm-kafka/README.md b/external/storm-kafka/README.md
index 73cf334..bd61f13 100644
--- a/external/storm-kafka/README.md
+++ b/external/storm-kafka/README.md
@@ -33,9 +33,9 @@ of this class you need to first construct an instance of GlobalPartitionInformat
Broker brokerForPartition1 = new Broker("localhost", 9092);//localhost:9092 but we specified the port explicitly
Broker brokerForPartition2 = new Broker("localhost:9092");//localhost:9092 specified as one string.
GlobalPartitionInformation partitionInfo = new GlobalPartitionInformation();
- partitionInfo.add(0, brokerForPartition0)//mapping form partition 0 to brokerForPartition0
- partitionInfo.add(1, brokerForPartition1)//mapping form partition 1 to brokerForPartition1
- partitionInfo.add(2, brokerForPartition2)//mapping form partition 2 to brokerForPartition2
+ partitionInfo.addPartition(0, brokerForPartition0);//mapping form partition 0 to brokerForPartition0
+ partitionInfo.addPartition(1, brokerForPartition1);//mapping form partition 1 to brokerForPartition1
+ partitionInfo.addPartition(2, brokerForPartition2);//mapping form partition 2 to brokerForPartition2
StaticHosts hosts = new StaticHosts(partitionInfo);
```