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/09/30 23:11:55 UTC
[1/3] storm git commit: correct storm-kafka readme file
Repository: storm
Updated Branches:
refs/heads/master b76d90bb1 -> ce93d5f69
correct storm-kafka readme file
correct readme file: link & configs
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/be7f2ad1
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/be7f2ad1
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/be7f2ad1
Branch: refs/heads/master
Commit: be7f2ad1d9b6be1a92fb2a8775822b5752703c89
Parents: 4523e54
Author: Xin Wang <be...@163.com>
Authored: Fri Sep 18 15:19:44 2015 +0800
Committer: Xin Wang <be...@163.com>
Committed: Fri Sep 18 15:19:44 2015 +0800
----------------------------------------------------------------------
external/storm-kafka/README.md | 16 +++++++++-------
1 file changed, 9 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/be7f2ad1/external/storm-kafka/README.md
----------------------------------------------------------------------
diff --git a/external/storm-kafka/README.md b/external/storm-kafka/README.md
index 91c64bf..ed39dc5 100644
--- a/external/storm-kafka/README.md
+++ b/external/storm-kafka/README.md
@@ -218,7 +218,7 @@ You can return a null and the message will be ignored. If you have one static to
DefaultTopicSelector.java and set the name of the topic in the constructor.
### Specifying Kafka producer properties
-You can provide all the produce properties , see http://kafka.apache.org/documentation.html#producerconfigs
+You can provide all the produce properties , see http://kafka.apache.org/documentation.html#newproducerconfigs
section "Important configuration properties for the producer", in your Storm topology config by setting the properties
map with key kafka.broker.properties.
@@ -245,9 +245,10 @@ For the bolt :
Config conf = new Config();
//set producer properties.
Properties props = new Properties();
- props.put("metadata.broker.list", "localhost:9092");
- props.put("request.required.acks", "1");
- props.put("serializer.class", "kafka.serializer.StringEncoder");
+ props.put("bootstrap.servers", "localhost:9092");
+ props.put("acks", "1");
+ props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
+ props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
conf.put(KafkaBolt.KAFKA_BROKER_PROPERTIES, props);
StormSubmitter.submitTopology("kafkaboltTest", conf, builder.createTopology());
@@ -276,9 +277,10 @@ For Trident:
Config conf = new Config();
//set producer properties.
Properties props = new Properties();
- props.put("metadata.broker.list", "localhost:9092");
- props.put("request.required.acks", "1");
- props.put("serializer.class", "kafka.serializer.StringEncoder");
+ props.put("bootstrap.servers", "localhost:9092");
+ props.put("acks", "1");
+ props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
+ props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
conf.put(TridentKafkaState.KAFKA_BROKER_PROPERTIES, props);
StormSubmitter.submitTopology("kafkaTridentTest", conf, topology.build());
```
[3/3] storm git commit: added STORM-1053 to Changelog
Posted by bo...@apache.org.
added STORM-1053 to Changelog
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/ce93d5f6
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/ce93d5f6
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/ce93d5f6
Branch: refs/heads/master
Commit: ce93d5f69ba4554681dcba9dd684fe70179e8250
Parents: a73e5e2
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Wed Sep 30 16:11:08 2015 -0500
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Wed Sep 30 16:11:08 2015 -0500
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/ce93d5f6/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index a071591..2071434 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
## 0.11.0
+ * STORM-1053: Update storm-kafka README for new producer API confs.
* STORM-1058: create CLI kill_workers to kill workers on a supervisor node
* STORM-1063: support relative log4j conf dir for both daemons and workers
* STORM-1059: Upgrade Storm to use Clojure 1.7.0
[2/3] storm git commit: Merge branch 'patch-7' of
https://github.com/vesense/storm into STORM-1053
Posted by bo...@apache.org.
Merge branch 'patch-7' of https://github.com/vesense/storm into STORM-1053
STORM-1053: Update storm-kafka README for new producer API confs.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a73e5e2c
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a73e5e2c
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a73e5e2c
Branch: refs/heads/master
Commit: a73e5e2c310bd6ea5e5054f9b1f89345b9a4c32d
Parents: b76d90b be7f2ad
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Wed Sep 30 16:10:00 2015 -0500
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Wed Sep 30 16:10:00 2015 -0500
----------------------------------------------------------------------
external/storm-kafka/README.md | 16 +++++++++-------
1 file changed, 9 insertions(+), 7 deletions(-)
----------------------------------------------------------------------