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:02:56 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 8b75a016d -> 5e4600ae4


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


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

Branch: refs/heads/trunk
Commit: 5e4600ae469559b9cdb36c17efb90cc6b6388826
Parents: 8b75a01
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:02:26 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/5e4600ae/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