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 2015/05/22 22:03:59 UTC
[2/5] storm git commit: More corrections.
More corrections.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/b968d413
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/b968d413
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/b968d413
Branch: refs/heads/master
Commit: b968d413f05e39a206352fb5d82bd50003878f36
Parents: 1f0aad4
Author: jangie <ja...@gmail.com>
Authored: Fri Mar 20 16:02:07 2015 -0400
Committer: jangie <ja...@gmail.com>
Committed: Fri Mar 20 16:02:07 2015 -0400
----------------------------------------------------------------------
external/storm-kafka/README.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/b968d413/external/storm-kafka/README.md
----------------------------------------------------------------------
diff --git a/external/storm-kafka/README.md b/external/storm-kafka/README.md
index 8644696..666a086 100644
--- a/external/storm-kafka/README.md
+++ b/external/storm-kafka/README.md
@@ -203,8 +203,8 @@ For the bolt :
spout.setCycle(true);
builder.setSpout("spout", spout, 5);
KafkaBolt bolt = new KafkaBolt()
- .withKafkaTopicSelector(new DefaultTopicSelector("test"))
- .withTridentTupleToKafkaMapper(new FieldNameBasedTupleToKafkaMapper());
+ .withTopicSelector(new DefaultTopicSelector("test"))
+ .withTupleToKafkaMapper(new FieldNameBasedTupleToKafkaMapper());
builder.setBolt("forwardToKafka", bolt, 8).shuffleGrouping("spout");
Config conf = new Config();