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.")

Reply via email to