lucasbru opened a new pull request, #23670: URL: https://github.com/apache/kafka/pull/23670
StreamsGroupTopologyDescriptionRequestTest only ever exercises InMemoryTopologyDescriptionPlugin, which never fails, so the permanent and transient failure classification for the StreamsGroupTopologyDescriptionUpdate RPC, and the DeleteGroups plugin-failure path, were proven only against mocks in GroupCoordinatorServiceTopologyDescriptionTest, never against a real broker/RPC round trip. This adds FailingTopologyDescriptionPlugin, a configurable test double whose setTopology and deleteTopology calls can be told to fail on demand, and three new cluster tests built on it. A permanent setTopology failure surfaces STREAMS_TOPOLOGY_DESCRIPTION_UPDATE_FAILED with the plugin's message and stops the broker from re-soliciting a push at that epoch. A transient failure returns the same error code but arms the heartbeat back-off instead of ratcheting the epoch. A DeleteGroups plugin failure returns GROUP_DELETION_FAILED without tombstoning the group, and a retried delete succeeds once the plugin recovers. KSTREAMS-9351 -- 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]
