kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-4262; Increase data volume in replication test
Date Fri, 07 Oct 2016 14:03:06 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.1 db45b1819 -> 7232a031b


KAFKA-4262; Increase data volume in replication test

To prevent test from completing without throttling before config change takes effect, produce
more messages in the test.

Author: Rajini Sivaram <rajinisivaram@googlemail.com>

Reviewers: Ben Stopford <benstopford@gmail.com>, Ismael Juma <ismael@juma.me.uk>

Closes #1982 from rajinisivaram/KAFKA-4262

(cherry picked from commit 5e4600ae469559b9cdb36c17efb90cc6b6388826)
Signed-off-by: Ismael Juma <ismael@juma.me.uk>


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

Branch: refs/heads/0.10.1
Commit: 7232a031b5d9454fe917025875f6f04fcf36e282
Parents: db45b18
Author: Rajini Sivaram <rajinisivaram@googlemail.com>
Authored: Fri Oct 7 15:02:26 2016 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Fri Oct 7 15:03:00 2016 +0100

----------------------------------------------------------------------
 .../scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/7232a031/core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala b/core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala
index 6d29211..95ee5d3 100644
--- a/core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala
+++ b/core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala
@@ -113,9 +113,9 @@ class ReassignPartitionsClusterTest extends ZooKeeperTestHarness with
Logging {
     ), servers = servers)
 
     //Given throttle set so replication will take a certain number of secs
-    val initialThrottle: Long = 1000 * 1000
+    val initialThrottle: Long = 10 * 1000 * 1000
     val expectedDurationSecs = 5
-    val numMessages: Int = 50
+    val numMessages: Int = 500
     val msgSize: Int = 100 * 1000
     produceMessages(servers, topicName, numMessages, acks = 0, msgSize)
     assertEquals(expectedDurationSecs, numMessages * msgSize / initialThrottle)


Mime
View raw message