root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

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 <lbrutschy@confluent.io>
This commit is contained in:
Kuan-Po Tseng 2025-06-02 16:40:59 +08:00 committed by GitHub
parent 8f1a1cd838
commit 8d0097f60c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/kafkatest/services/kafka/kafka.py
View File

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