Harsh-99999 opened a new pull request, #23523:
URL: https://github.com/apache/kafka/pull/23523
Adds a system test verifying that a newer (dev/4.4+) Kafka Streams client
using static membership on the `streams` group protocol correctly detects and
fails against an older broker (4.2/4.3) that doesn't support the `streams`
group protocol.
The client sends a `STREAMS_GROUP_HEARTBEAT` request, which the old broker
rejects with `INVALID_REQUEST` ("Static membership is not yet supported"). The
client then transitions to the terminal `ERROR` state rather than hanging or
retrying indefinitely.
Note on scope: this PR originally also covered the reverse case (old client
vs new broker), but that direction fails with a client-side `ConfigException`
during `StreamsConfig` construction, before any broker contact. This is a local
configuration guard rather than a cross-version compatibility issue, and is
already covered by unit tests. Per discussion on the ticket, that direction has
been dropped from this PR.
Testing:
* Verified against Kafka 4.2.1.
* Verified against Kafka 4.3.1.
* Ran the test both in isolation and as part of the full
`StreamsStaticMembershipTest` suite.
--
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]
