kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-4689; Disable system tests for consumer hard failures
Date Thu, 30 Mar 2017 22:52:12 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 15e0234a5 -> 93d451cee


KAFKA-4689; Disable system tests for consumer hard failures

See the JIRA for the full details. Essentially the test assertions depend on receiving reliable
events from the consumer processes, but this is not generally possible in the presence of
a hard failure (i.e. `kill -9`). Until we solve this problem, the hard failure scenarios will
be turned off.

Author: Jason Gustafson <jason@confluent.io>

Reviewers: Apurva Mehta <apurva@confluent.io>, Ismael Juma <ismael@juma.me.uk>

Closes #2771 from hachikuji/KAFKA-4689


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

Branch: refs/heads/trunk
Commit: 93d451ceeb00a150bbbdae3f0601620b902b7c87
Parents: 15e0234
Author: Jason Gustafson <jason@confluent.io>
Authored: Thu Mar 30 23:52:03 2017 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Thu Mar 30 23:52:03 2017 +0100

----------------------------------------------------------------------
 tests/kafkatest/tests/client/consumer_test.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/93d451ce/tests/kafkatest/tests/client/consumer_test.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/tests/client/consumer_test.py b/tests/kafkatest/tests/client/consumer_test.py
index 999b85c..a7ec9c8 100644
--- a/tests/kafkatest/tests/client/consumer_test.py
+++ b/tests/kafkatest/tests/client/consumer_test.py
@@ -117,7 +117,7 @@ class OffsetValidationTest(VerifiableConsumerTest):
             (consumer.total_consumed(), consumer.current_position(partition))
 
     @cluster(num_nodes=7)
-    @matrix(clean_shutdown=[True, False], bounce_mode=["all", "rolling"])
+    @matrix(clean_shutdown=[True], bounce_mode=["all", "rolling"])
     def test_consumer_bounce(self, clean_shutdown, bounce_mode):
         """
         Verify correct consumer behavior when the consumers in the group are consecutively
restarted.
@@ -160,7 +160,7 @@ class OffsetValidationTest(VerifiableConsumerTest):
                 (consumer.current_position(partition), consumer.total_consumed())
 
     @cluster(num_nodes=7)
-    @matrix(clean_shutdown=[True, False], enable_autocommit=[True, False])
+    @matrix(clean_shutdown=[True], enable_autocommit=[True, False])
     def test_consumer_failure(self, clean_shutdown, enable_autocommit):
         partition = TopicPartition(self.TOPIC, 0)
         


Mime
View raw message