From d75e5fbed635a4c096c98d0abf25236c8616503d Mon Sep 17 00:00:00 2001 From: zhuol Date: Thu, 24 Sep 2015 11:20:37 -0500 Subject: [PATCH] STORM-1068, configure request.required.acks in KafkaUtilsTest --- external/storm-kafka/src/test/storm/kafka/KafkaUtilsTest.java | 1 + 1 file changed, 1 insertion(+) diff --git a/external/storm-kafka/src/test/storm/kafka/KafkaUtilsTest.java b/external/storm-kafka/src/test/storm/kafka/KafkaUtilsTest.java index a2d2af8d25a..0e4f3512000 100644 --- a/external/storm-kafka/src/test/storm/kafka/KafkaUtilsTest.java +++ b/external/storm-kafka/src/test/storm/kafka/KafkaUtilsTest.java @@ -195,6 +195,7 @@ private void createTopicAndSendMessage(String value) { private void createTopicAndSendMessage(String key, String value) { Properties p = new Properties(); + p.put("request.required.acks", "1"); p.put("serializer.class", "kafka.serializer.StringEncoder"); p.put("bootstrap.servers", broker.getBrokerConnectionString()); p.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");