Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

use sync kafka producer for deterministic test (#3721)

This commit is contained in:
Parag Jain 2016-11-29 12:04:51 -06:00 committed by Gian Merlino
parent 2640d170c3
commit 877992fe63
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
integration-tests/src/test/java/io/druid/tests/indexer/ITKafkaTest.java
View File

@ -158,7 +158,7 @@ public class ITKafkaTest extends AbstractIndexerTest
LOG.info("kafka host: [%s]", config.getKafkaHost()); LOG.info("kafka host: [%s]", config.getKafkaHost());
properties.put("serializer.class", "kafka.serializer.StringEncoder"); properties.put("serializer.class", "kafka.serializer.StringEncoder");
properties.put("request.required.acks", "1"); 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); ProducerConfig producerConfig = new ProducerConfig(properties);
Producer<String, String> producer = new Producer<String, String>(producerConfig); Producer<String, String> producer = new Producer<String, String>(producerConfig);