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:23 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.2 4b8c73615 -> e3c5f4122


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

(cherry picked from commit 93d451ceeb00a150bbbdae3f0601620b902b7c87)
Signed-off-by: Ismael Juma <ismael@juma.me.uk>


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

Branch: refs/heads/0.10.2
Commit: e3c5f41229f1cd07bd5645e596348ebb14c02370
Parents: 4b8c736
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:20 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/e3c5f412/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 9c55955..9eb5ab6 100644
--- a/tests/kafkatest/tests/client/consumer_test.py
+++ b/tests/kafkatest/tests/client/consumer_test.py
@@ -116,7 +116,7 @@ class OffsetValidationTest(VerifiableConsumerTest):
             "Total consumed records did not match consumed position"
 
     @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.
@@ -159,7 +159,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