lucliu1108 opened a new pull request, #22640: URL: https://github.com/apache/kafka/pull/22640
## Summary Adds the client-side request manager that pushes topology descriptions to the broker, wires the heartbeat path to flip the push-required flag on responses, and registers the new manager in the consumer network thread. Should be based on https://github.com/apache/kafka/pull/22639 ## File changes - **`StreamsGroupTopologyDescriptionRequestManager`**: new RequestManager that implements the KIP-1331 response handling with unit tests. - **`StreamsGroupHeartbeatRequestManager`**: `onSuccessResponse` propagates `memberId` and sets `topologyPushRequired` when the broker requests a push, with unit tests. - **`RequestManagers`**: registers the new manager in the Streams branch and the entries list. Current tests updated. - **`StreamThread.initStreamsRebalanceData`**: bumped to package-private for testing. 2 new tests verify the wire description is populated/skipped based on the config. -- 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]
