frankvicky opened a new pull request, #22552: URL: https://github.com/apache/kafka/pull/22552
Adds the StreamsGroupTopologyDescriptionUpdate RPC handler stacked on the heartbeat extension (1/3). The push pipeline runs through `TopologyDescriptionManager.handleSetTopology`: `validate (group, member)`, convert wire payload, call `plugin.setTopology`, persist `StoredDescriptionTopologyEpoch` on success or `FailedDescriptionTopologyEpoch` on permanent failure, and centralise back-off state mutations in a single `whenComplete`. -- 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]
