This is an automated email from the ASF dual-hosted git repository.
chia7712 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 a37e79a47af MINOR: Fix use_transactions_v2 usage in e2e (#21164)
a37e79a47af is described below
commit a37e79a47afe1f3f05bf0dd0167659b4488559be
Author: Ming-Yen Chung <[email protected]>
AuthorDate: Wed Dec 24 17:56:53 2025 +0800
MINOR: Fix use_transactions_v2 usage in e2e (#21164)
The use_transaction_v2 should be passed to controller node in isolated
controller. Otherwise, the transaction v2 won't be enabled.
Reviewers: Justine Olshan <[email protected]>, Andrew Schofield
<[email protected]>, Chia-Ping Tsai <[email protected]>
---
tests/kafkatest/services/kafka/kafka.py | 1 +
1 file changed, 1 insertion(+)
diff --git a/tests/kafkatest/services/kafka/kafka.py
b/tests/kafkatest/services/kafka/kafka.py
index 41227716b9f..04d3457f3b7 100644
--- a/tests/kafkatest/services/kafka/kafka.py
+++ b/tests/kafkatest/services/kafka/kafka.py
@@ -358,6 +358,7 @@ class KafkaService(KafkaPathResolverMixin, JmxMixin,
Service):
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_share_groups=self.use_share_groups,
use_streams_groups=self.use_streams_groups
)
self.controller_quorum = self.isolated_controller_quorum
