From ec3cc4adcebdce213a023c4ec8081aa1132f78cf Mon Sep 17 00:00:00 2001 From: Rajini Sivaram Date: Fri, 7 Oct 2016 18:32:29 +0100 Subject: [PATCH] KAFKA-4265: Run replication quotas test with producer acks=1 --- .../test/scala/unit/kafka/server/ReplicationQuotasTest.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.scala b/core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.scala index 511052d8729cd..825b2b40b1e94 100644 --- a/core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.scala +++ b/core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.scala @@ -119,7 +119,7 @@ class ReplicationQuotasTest extends ZooKeeperTestHarness { changeTopicConfig(zkUtils, topic, propsWith(FollowerReplicationThrottledReplicasProp, "0:106,1:106,2:106,3:107,4:107,5:107")) //Add data equally to each partition - producer = createNewProducer(getBrokerListStrFromServers(brokers), retries = 5, acks = 0) + producer = createNewProducer(getBrokerListStrFromServers(brokers), retries = 5, acks = 1) (0 until msgCount).foreach { x => (0 to 7).foreach { partition => producer.send(new ProducerRecord(topic, partition, null, msg))