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 <apu...@confluent.io>

Reviewers: Ismael Juma <ism...@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 <apu...@confluent.io>
Authored: Sat Feb 18 06:38:35 2017 -0800
Committer: Ismael Juma <ism...@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,

Reply via email to