MdTanwer opened a new pull request, #23255: URL: https://github.com/apache/kafka/pull/23255
## Summary - Interactive Query hashed keys using the host-endpoint map size, so a streams-protocol rebalance that omitted an in-flight task shrank the modulo (e.g. 4 → 3) and routed keys to a live wrong host. Callers saw empty results with no exception. - StreamsGroupHeartbeat v2 now sends source/repartition topic partition counts from broker metadata. The client uses those counts for hashing; the host map still lists only currently assigned, queryable partitions. Missing partitions resolve to `HostInfo.unavailable()`. - Classic protocol is unchanged. Members with `application.server=null` no longer shrink the modulo for the streams protocol; those tasks stay unqueryable. ## Test plan - [x] `StreamsMetadataStateTest.shouldReturnUnavailableHostWhenPartitionIsOmittedFromHostMetadataIfPartitionCountIsKnown` - [x] `StreamThreadTest.testGetTopicPartitionInfoFillsMissingPartitionsFromCounts` - [x] `EndpointToPartitionsManagerTest` partition-count tests - [x] `GroupMetadataManagerTest` endpoint + topic partition count assertions - [x] `StreamsGroupHeartbeatResponseTest` v0/v1/v2 field compatibility - [x] `RequestResponseTest.testSerialization` - [ ] Broader `GroupMetadataManagerTest` streams heartbeat suite / IQ integration tests - [ ] Confirm whether a KIP is required for the StreamsGroupHeartbeat v2 field Made with [Cursor](https://cursor.com) -- 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]
