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:01 UTC
[4/5] storm git commit: Merge branch 'patch-1' of
https://github.com/jangie/storm into docs-update
Merge branch 'patch-1' of https://github.com/jangie/storm into docs-update
Documentation code corrections
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2d388fa1
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2d388fa1
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2d388fa1
Branch: refs/heads/master
Commit: 2d388fa15a527053572e0be83f9c208a34da5464
Parents: 2195fd6 1b4ea1e
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Fri May 22 15:02:02 2015 -0500
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Fri May 22 15:02:02 2015 -0500
----------------------------------------------------------------------
external/storm-kafka/README.md | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/2d388fa1/external/storm-kafka/README.md
----------------------------------------------------------------------
diff --cc external/storm-kafka/README.md
index da8a49a,44b4799..1e9cc12
--- a/external/storm-kafka/README.md
+++ b/external/storm-kafka/README.md
@@@ -112,11 -108,10 +112,11 @@@ outputField is "bytes". There are alte
```java
BrokerHosts hosts = new ZkHosts(zkConnString);
SpoutConfig spoutConfig = new SpoutConfig(hosts, topicName, "/" + topicName, UUID.randomUUID().toString());
- spoutConf.scheme = new SchemeAsMultiScheme(new StringScheme());
+ spoutConfig.scheme = new SchemeAsMultiScheme(new StringScheme());
KafkaSpout kafkaSpout = new KafkaSpout(spoutConfig);
```
-####Trident Spout
+
+#### Trident Spout
```java
TridentTopology topology = new TridentTopology();
BrokerHosts zk = new ZkHosts("localhost");