Repository: kafka
Updated Branches:
  refs/heads/trunk 6acbf27ae -> f396fdac1


KAFKA-4193; Fix for intermittent failure in FetcherTest

Author: Ben Stopford <benstopf...@gmail.com>

Reviewers: Jason Gustafson <ja...@confluent.io>

Closes #1881 from benstopford/KAFKA-4193


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f396fdac
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/f396fdac
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/f396fdac

Branch: refs/heads/trunk
Commit: f396fdac197409fb955f00a6f642f04e4926ba41
Parents: 6acbf27
Author: Ben Stopford <benstopf...@gmail.com>
Authored: Mon Sep 19 23:17:23 2016 -0700
Committer: Jason Gustafson <ja...@confluent.io>
Committed: Mon Sep 19 23:17:23 2016 -0700

----------------------------------------------------------------------
 core/src/test/scala/unit/kafka/utils/TestUtils.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/f396fdac/core/src/test/scala/unit/kafka/utils/TestUtils.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/utils/TestUtils.scala 
b/core/src/test/scala/unit/kafka/utils/TestUtils.scala
index dadc8a3..4e1d278 100755
--- a/core/src/test/scala/unit/kafka/utils/TestUtils.scala
+++ b/core/src/test/scala/unit/kafka/utils/TestUtils.scala
@@ -934,7 +934,7 @@ object TestUtils extends Logging {
   def produceMessages(servers: Seq[KafkaServer],
                       topic: String,
                       numMessages: Int,
-                      acks: Int = 0,
+                      acks: Int = -1,
                       valueBytes: Int = -1): Seq[Array[Byte]] = {
 
     val producer = createNewProducer(

Reply via email to