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 <[email protected]> Reviewers: Ben Stopford <[email protected]>, Ismael Juma <[email protected]> Closes #1982 from rajinisivaram/KAFKA-4262 (cherry picked from commit 5e4600ae469559b9cdb36c17efb90cc6b6388826) Signed-off-by: Ismael Juma <[email protected]> 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 <[email protected]> Authored: Fri Oct 7 15:02:26 2016 +0100 Committer: Ismael Juma <[email protected]> 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)
