You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2017/03/30 22:52:12 UTC
kafka git commit: KAFKA-4689;
Disable system tests for consumer hard failures
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 <ja...@confluent.io>
Reviewers: Apurva Mehta <ap...@confluent.io>, Ismael Juma <is...@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 <ja...@confluent.io>
Authored: Thu Mar 30 23:52:03 2017 +0100
Committer: Ismael Juma <is...@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)