This is an automated email from the ASF dual-hosted git repository.
lucasbru 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 8d0097f60c8 MINOR: fix failed StreamsBrokerBounceTest e2e tests
(#19839)
8d0097f60c8 is described below
commit 8d0097f60c834830315cacd858c220f9be800756
Author: Kuan-Po Tseng <brandb...@gmail.com>
AuthorDate: Mon Jun 2 16:40:59 2025 +0800
MINOR: fix failed StreamsBrokerBounceTest e2e tests (#19839)
Currently some tests in StreamsBrokersBounceTest failed due to error
`The cluster does not support the STREAMS group protocol or does not
support the versions of the STREAMS group protocol used by this client
(used versions: 0 to 0).`
The reason is that under isolated kraft mode, we missed to set both
`unstable.api.versions.enable` and `unstable.feature.versions.enable` to
true to all controllers, which cause `streams.version` fallback to 0 in
the broker side and the above error raise when
StreamsGroupRequestHeartbeat comes to the broker.
This patch add the missing configs to controllers properties if streams
group protocol is used.
Reviewers: Lucas Brutschy <lbruts...@confluent.io>
---
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 b490f75fbac..79c2fb81b26 100644
--- a/tests/kafkatest/services/kafka/kafka.py
+++ b/tests/kafkatest/services/kafka/kafka.py
@@ -357,7 +357,8 @@ class KafkaService(KafkaPathResolverMixin, JmxMixin,
Service):
listener_security_config=listener_security_config,
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
+ server_prop_overrides=server_prop_overrides,
dynamicRaftQuorum=self.dynamicRaftQuorum,
+ use_streams_groups=self.use_streams_groups
)
self.controller_quorum = self.isolated_controller_quorum
