use new kafka producer configs Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5c38b91a Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5c38b91a Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5c38b91a
Branch: refs/heads/master Commit: 5c38b91accb9b9f5adfeea412bac0e457508f492 Parents: df417e0 Author: Xin Wang <[email protected]> Authored: Fri Sep 18 14:05:21 2015 +0800 Committer: Xin Wang <[email protected]> Committed: Fri Sep 18 14:05:21 2015 +0800 ---------------------------------------------------------------------- .../src/test/storm/kafka/TridentKafkaTopology.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/5c38b91a/external/storm-kafka/src/test/storm/kafka/TridentKafkaTopology.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/test/storm/kafka/TridentKafkaTopology.java b/external/storm-kafka/src/test/storm/kafka/TridentKafkaTopology.java index 9cb7bbf..cade6df 100644 --- a/external/storm-kafka/src/test/storm/kafka/TridentKafkaTopology.java +++ b/external/storm-kafka/src/test/storm/kafka/TridentKafkaTopology.java @@ -88,11 +88,11 @@ public class TridentKafkaTopology { private static Config getConfig(String brokerConnectionString) { Config conf = new Config(); - Map config = new HashMap(); Properties props = new Properties(); - props.put("metadata.broker.list", brokerConnectionString); - props.put("request.required.acks", "1"); - props.put("serializer.class", "kafka.serializer.StringEncoder"); + props.put("bootstrap.servers", brokerConnectionString); + 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); return conf; }
