Repository: kafka
Updated Branches:
  refs/heads/0.10.1 eaaa433fc -> f66e88a30


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

(cherry picked from commit f396fdac197409fb955f00a6f642f04e4926ba41)
Signed-off-by: Jason Gustafson <ja...@confluent.io>


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

Branch: refs/heads/0.10.1
Commit: f66e88a30b2aabd02bc0ef35fa27f8bd9b35466f
Parents: eaaa433
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:40 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/f66e88a3/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