From 3f8e8f0b3275f6d509b710dda49d0a896b03106c Mon Sep 17 00:00:00 2001 From: Ming-Yen Chung Date: Tue, 16 Dec 2025 13:55:36 +0800 Subject: [PATCH 1/2] Fix use_transaction_v2 usage in e2e --- tests/kafkatest/services/kafka/kafka.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/kafkatest/services/kafka/kafka.py b/tests/kafkatest/services/kafka/kafka.py index 41227716b9fb2..ffe44b5315117 100644 --- a/tests/kafkatest/services/kafka/kafka.py +++ b/tests/kafkatest/services/kafka/kafka.py @@ -358,7 +358,7 @@ def __init__(self, context, num_nodes, zk, security_protocol=SecurityConfig.PLAI extra_kafka_opts=extra_kafka_opts, tls_version=tls_version, isolated_kafka=self, allow_zk_with_kraft=self.allow_zk_with_kraft, server_prop_overrides=server_prop_overrides, dynamicRaftQuorum=self.dynamicRaftQuorum, - use_streams_groups=self.use_streams_groups + use_transactions_v2=self.use_transactions_v2, use_streams_groups=self.use_streams_groups ) self.controller_quorum = self.isolated_controller_quorum From 285274a2497abb309e41c72c5c1fe86836691a28 Mon Sep 17 00:00:00 2001 From: Ming-Yen Chung Date: Sat, 20 Dec 2025 20:17:24 +0800 Subject: [PATCH 2/2] Add self.use_share_groups to init KafkaService for isolated_controller_quorum --- tests/kafkatest/services/kafka/kafka.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tests/kafkatest/services/kafka/kafka.py b/tests/kafkatest/services/kafka/kafka.py index ffe44b5315117..04d3457f3b7a4 100644 --- a/tests/kafkatest/services/kafka/kafka.py +++ b/tests/kafkatest/services/kafka/kafka.py @@ -358,7 +358,8 @@ def __init__(self, context, num_nodes, zk, security_protocol=SecurityConfig.PLAI extra_kafka_opts=extra_kafka_opts, tls_version=tls_version, isolated_kafka=self, allow_zk_with_kraft=self.allow_zk_with_kraft, server_prop_overrides=server_prop_overrides, dynamicRaftQuorum=self.dynamicRaftQuorum, - use_transactions_v2=self.use_transactions_v2, use_streams_groups=self.use_streams_groups + use_transactions_v2=self.use_transactions_v2, use_share_groups=self.use_share_groups, + use_streams_groups=self.use_streams_groups ) self.controller_quorum = self.isolated_controller_quorum