From 877992fe638b7d80c8fd9b90d811709200081664 Mon Sep 17 00:00:00 2001
From: Parag Jain <pjain1@users.noreply.github.com>
Date: Tue, 29 Nov 2016 12:04:51 -0600
Subject: [PATCH] use sync kafka producer for deterministic test (#3721)

---
 .../src/test/java/io/druid/tests/indexer/ITKafkaTest.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/integration-tests/src/test/java/io/druid/tests/indexer/ITKafkaTest.java b/integration-tests/src/test/java/io/druid/tests/indexer/ITKafkaTest.java
index e395e4c38b2..68ae5e4b3c6 100644
--- a/integration-tests/src/test/java/io/druid/tests/indexer/ITKafkaTest.java
+++ b/integration-tests/src/test/java/io/druid/tests/indexer/ITKafkaTest.java
@@ -158,7 +158,7 @@ public class ITKafkaTest extends AbstractIndexerTest
     LOG.info("kafka host: [%s]", config.getKafkaHost());
     properties.put("serializer.class", "kafka.serializer.StringEncoder");
     properties.put("request.required.acks", "1");
-    properties.put("producer.type", "async");
+    properties.put("producer.type", "sync"); // use sync producer for deterministic test
     ProducerConfig producerConfig = new ProducerConfig(properties);
     Producer<String, String> producer = new Producer<String, String>(producerConfig);