brandboat opened a new pull request, #19839:
URL: https://github.com/apache/kafka/pull/19839
Currently some tests in StreamsBrokersBounceTest failed due to error:
```
870b4b8f-a765-4001-9b53-6b900b18f66a: FATAL: An unexpected exception is
encountered on thread StreamsThread threadId:
SmokeTest-870b4b8f-a765-4001-9b53-6b900b18f66a-StreamThread-2
TaskManager
MetadataState:
Tasks:
: org.apache.kafka.streams.errors.StreamsException:
org.apache.kafka.common.errors.UnsupportedVersionException: 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).
org.apache.kafka.streams.errors.StreamsException:
org.apache.kafka.common.errors.UnsupportedVersionException: 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).
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(streamthread.java:966)
at
[org.apache.kafka.streams.processor.internals.StreamThread.run](https://github.com/apache/kafka/compare/org.apache.kafka.streams.processor.internals.StreamThread.run)(streamthread.java:888)
```
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.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
