update TestUtils kafka configs Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/58f09942 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/58f09942 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/58f09942
Branch: refs/heads/master Commit: 58f099421eeed8286d1e7729dad45a60de38f0c8 Parents: faa33f9 Author: Xin Wang <[email protected]> Authored: Thu Nov 5 11:27:30 2015 +0800 Committer: Xin Wang <[email protected]> Committed: Thu Nov 5 11:27:30 2015 +0800 ---------------------------------------------------------------------- external/storm-kafka/src/test/storm/kafka/TestUtils.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/58f09942/external/storm-kafka/src/test/storm/kafka/TestUtils.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/test/storm/kafka/TestUtils.java b/external/storm-kafka/src/test/storm/kafka/TestUtils.java index fa29992..1ec5d71 100644 --- a/external/storm-kafka/src/test/storm/kafka/TestUtils.java +++ b/external/storm-kafka/src/test/storm/kafka/TestUtils.java @@ -71,9 +71,10 @@ public class TestUtils { public static Config getConfig(String brokerConnectionString) { Config config = new Config(); 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"); config.put(KafkaBolt.KAFKA_BROKER_PROPERTIES, props); config.put(KafkaBolt.TOPIC, TOPIC);
