This is an automated email from the ASF dual-hosted git repository.
dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 24ce8c28520 KAFKA-20291 [4/N]: Fix consumer system tests (#21811)
24ce8c28520 is described below
commit 24ce8c285208c4b9e4bc9b43437e1f3fb2e8bba6
Author: Sean Quah <[email protected]>
AuthorDate: Wed Mar 18 22:38:37 2026 +0000
KAFKA-20291 [4/N]: Fix consumer system tests (#21811)
Add missing enable_assignment_batching parameter to
test_consumer_failure.
Reviewers: David Jacot <[email protected]>, Chia-Ping Tsai
<[email protected]>
---
tests/kafkatest/tests/client/consumer_test.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tests/kafkatest/tests/client/consumer_test.py
b/tests/kafkatest/tests/client/consumer_test.py
index 6b71d9769f7..3cb1b0a22d0 100644
--- a/tests/kafkatest/tests/client/consumer_test.py
+++ b/tests/kafkatest/tests/client/consumer_test.py
@@ -404,7 +404,7 @@ class OffsetValidationTest(VerifiableConsumerTest):
group_protocol=[consumer_group.consumer_group_protocol],
enable_assignment_batching=[False]
)
- def test_consumer_failure(self, clean_shutdown, enable_autocommit,
metadata_quorum=quorum.isolated_kraft, group_protocol=None):
+ def test_consumer_failure(self, clean_shutdown, enable_autocommit,
metadata_quorum=quorum.isolated_kraft, group_protocol=None,
enable_assignment_batching=True):
partition = TopicPartition(self.TOPIC, 0)
consumer = self.setup_consumer(self.TOPIC,
enable_autocommit=enable_autocommit, group_protocol=group_protocol)
