Repository: kafka Updated Branches: refs/heads/0.11.0 b81bf0e3d -> ef97ed7ee
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 (cherry picked from commit e5741b90cde98052c6f9172e12b8f06facb6e977) Signed-off-by: Jason Gustafson <ja...@confluent.io> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ef97ed7e Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ef97ed7e Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ef97ed7e Branch: refs/heads/0.11.0 Commit: ef97ed7ee5cb883a30245ea4f77ef99d4db15373 Parents: b81bf0e 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:15:10 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/ef97ed7e/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.")