kevin-wu24 opened a new pull request, #21619: URL: https://github.com/apache/kafka/pull/21619
### What changed Set `pendingRpc = false` when controller registration times out. If we do not set this, controllers cannot send `ControllerRegistrationRequests` thereafter. Instead, subsequent calls to `maybeSendControllerRegistration()` will always log: ``` maybeSendControllerRegistration: waiting for the previous RPC to complete. The asserts on L294 and L300 fail when `pendingRpc` does not get set in `onTimeout()`. ``` ### Tests Added `testRetransmitRegistrationAfterTimeout()`. This test times out a controller registration, and checks that the registration manager + channel manager's request queue state is as expected. -- 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]
