kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: MINOR: Increase consumer init timeout in throttling test
Date Mon, 20 Feb 2017 00:36:43 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.2 5d1bb0a9a -> 0790b352a


MINOR: Increase consumer init timeout in throttling test

The throttling system test sometimes fail because it takes longer than the current 10 second
time out for partitions to get assigned to the consumer.

Author: Apurva Mehta <apurva@confluent.io>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #2567 from apurvam/increase-timeout-for-partitions-assigned


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

Branch: refs/heads/0.10.2
Commit: 0790b352ab4f427584af8a7a2d18744c8f544ac8
Parents: 5d1bb0a
Author: Apurva Mehta <apurva@confluent.io>
Authored: Sat Feb 18 06:38:35 2017 -0800
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Mon Feb 20 00:36:37 2017 +0000

----------------------------------------------------------------------
 tests/kafkatest/tests/core/throttling_test.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/0790b352/tests/kafkatest/tests/core/throttling_test.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/tests/core/throttling_test.py b/tests/kafkatest/tests/core/throttling_test.py
index 17a60ea..a80af39 100644
--- a/tests/kafkatest/tests/core/throttling_test.py
+++ b/tests/kafkatest/tests/core/throttling_test.py
@@ -53,7 +53,7 @@ class ThrottlingTest(ProduceConsumeValidateTest):
         # ensure that the consumer is fully started before the producer starts
         # so that we don't miss any messages. This timeout ensures the sufficient
         # condition.
-        self.consumer_init_timeout_sec =  10
+        self.consumer_init_timeout_sec =  20
         self.num_brokers = 6
         self.num_partitions = 3
         self.kafka = KafkaService(test_context,


Mime
View raw message