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/05/28 15:50:01 UTC
[03/12] git commit: Improve Markdown formatting
Improve Markdown formatting
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/60c472f9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/60c472f9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/60c472f9
Branch: refs/heads/security
Commit: 60c472f9049e86d565ff6cf6e22ed355c6366f58
Parents: 4f0d45e
Author: Michael G. Noll <mi...@apache.org>
Authored: Thu May 22 10:54:18 2014 +0200
Committer: Michael G. Noll <mi...@apache.org>
Committed: Thu May 22 10:54:18 2014 +0200
----------------------------------------------------------------------
external/storm-kafka/README.md | 21 ++++++++-------------
1 file changed, 8 insertions(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/60c472f9/external/storm-kafka/README.md
----------------------------------------------------------------------
diff --git a/external/storm-kafka/README.md b/external/storm-kafka/README.md
index 726cff6..00eb238 100644
--- a/external/storm-kafka/README.md
+++ b/external/storm-kafka/README.md
@@ -4,22 +4,17 @@ Storm Kafka
Provides core storm and Trident spout implementations for consuming data from Apache Kafka 0.8.x.
-
-##Usage Example
+## Usage Example
```java
-
- TridentTopology topology = new TridentTopology();
-
- BrokerHosts zk = new ZkHosts("localhost");
-
- TridentKafkaConfig spoutConf = new TridentKafkaConfig(zk, "test-topic");
- spoutConf.scheme = new SchemeAsMultiScheme(new StringScheme());
- OpaqueTridentKafkaSpout spout = new OpaqueTridentKafkaSpout(spoutConf);
-
-
+TridentTopology topology = new TridentTopology();
+BrokerHosts zk = new ZkHosts("localhost");
+TridentKafkaConfig spoutConf = new TridentKafkaConfig(zk, "test-topic");
+spoutConf.scheme = new SchemeAsMultiScheme(new StringScheme());
+OpaqueTridentKafkaSpout spout = new OpaqueTridentKafkaSpout(spoutConf);
```
+
## Committer Sponsors
- * P. Taylor Goetz ([ptgoetz@apache.org](mailto:ptgoetz@apache.org))
\ No newline at end of file
+ * P. Taylor Goetz ([ptgoetz@apache.org](mailto:ptgoetz@apache.org))