You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2016/10/07 14:02:56 UTC
kafka git commit: KAFKA-4262; Increase data volume in replication test
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 <ra...@googlemail.com>
Reviewers: Ben Stopford <be...@gmail.com>, Ismael Juma <is...@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 <ra...@googlemail.com>
Authored: Fri Oct 7 15:02:26 2016 +0100
Committer: Ismael Juma <is...@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)