Repository: kafka Updated Branches: refs/heads/trunk 043951753 -> e5741b90c
MINOR: Increase number of messages in replica verification tool test Increase the number of messages produced to make the test more reliable. The test failed in a recent build and also fails intermittently when run locally. Since the producer uses acks=0 and the test stops as soon as a lag is observed, the change shouldn't have a big impact on the time taken to run when lag is observed sooner. Author: Rajini Sivaram <rajinisiva...@googlemail.com> Reviewers: Jason Gustafson <ja...@confluent.io> Closes #4312 from rajinisivaram/MINOR-replicaverification-test Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e5741b90 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/e5741b90 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/e5741b90 Branch: refs/heads/trunk Commit: e5741b90cde98052c6f9172e12b8f06facb6e977 Parents: 0439517 Author: Rajini Sivaram <rajinisiva...@googlemail.com> Authored: Mon Dec 11 11:12:55 2017 -0800 Committer: Jason Gustafson <ja...@confluent.io> Committed: Mon Dec 11 11:13:57 2017 -0800 ---------------------------------------------------------------------- tests/kafkatest/tests/tools/replica_verification_test.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/e5741b90/tests/kafkatest/tests/tools/replica_verification_test.py ---------------------------------------------------------------------- diff --git a/tests/kafkatest/tests/tools/replica_verification_test.py b/tests/kafkatest/tests/tools/replica_verification_test.py index a5b3390..f296c73 100644 --- a/tests/kafkatest/tests/tools/replica_verification_test.py +++ b/tests/kafkatest/tests/tools/replica_verification_test.py @@ -84,7 +84,7 @@ class ReplicaVerificationToolTest(Test): err_msg="Timed out waiting to reach zero replica lags.") self.stop_producer() - self.start_producer(max_messages=1000, acks=0, timeout=5) + self.start_producer(max_messages=10000, acks=0, timeout=5) # Verify that there is lag in replicas and is correctly reported by ReplicaVerificationTool wait_until(lambda: self.replica_verifier.get_lag_for_partition(TOPIC, 0) > 0, timeout_sec=10, - err_msg="Timed out waiting to reach non-zero number of replica lags.") \ No newline at end of file + err_msg="Timed out waiting to reach non-zero number of replica lags.")
