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:04:00 UTC
[3/5] storm git commit: Currently same value, but this is more clear
Currently same value, but this is more clear
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1b4ea1eb
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1b4ea1eb
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1b4ea1eb
Branch: refs/heads/master
Commit: 1b4ea1ebf55248cf1d11719839ea126837ec17d1
Parents: b968d41
Author: jangie <ja...@gmail.com>
Authored: Fri Mar 20 16:08:37 2015 -0400
Committer: jangie <ja...@gmail.com>
Committed: Fri Mar 20 16:08:37 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/1b4ea1eb/external/storm-kafka/README.md
----------------------------------------------------------------------
diff --git a/external/storm-kafka/README.md b/external/storm-kafka/README.md
index 666a086..44b4799 100644
--- a/external/storm-kafka/README.md
+++ b/external/storm-kafka/README.md
@@ -213,7 +213,7 @@ For the bolt :
props.put("metadata.broker.list", "localhost:9092");
props.put("request.required.acks", "1");
props.put("serializer.class", "kafka.serializer.StringEncoder");
- conf.put(TridentKafkaState.KAFKA_BROKER_PROPERTIES, props);
+ conf.put(KafkaBolt.KAFKA_BROKER_PROPERTIES, props);
StormSubmitter.submitTopology("kafkaboltTest", conf, builder.createTopology());
```