kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject kafka git commit: MINOR: Increase number of messages in replica verification tool test
Date Mon, 11 Dec 2017 19:15:44 GMT
Repository: kafka
Updated Branches:
  refs/heads/1.0 46fc8eca9 -> 3420cb3be


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 <rajinisivaram@googlemail.com>

Reviewers: Jason Gustafson <jason@confluent.io>

Closes #4312 from rajinisivaram/MINOR-replicaverification-test

(cherry picked from commit e5741b90cde98052c6f9172e12b8f06facb6e977)
Signed-off-by: Jason Gustafson <jason@confluent.io>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/3420cb3b
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/3420cb3b
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/3420cb3b

Branch: refs/heads/1.0
Commit: 3420cb3bea1702e09984f8ce9bff8546810c0161
Parents: 46fc8ec
Author: Rajini Sivaram <rajinisivaram@googlemail.com>
Authored: Mon Dec 11 11:12:55 2017 -0800
Committer: Jason Gustafson <jason@confluent.io>
Committed: Mon Dec 11 11:15:40 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/3420cb3b/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.")


Mime
View raw message