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)
|