akhileshchg opened a new pull request, #12961: URL: https://github.com/apache/kafka/pull/12961
KAFKA-14446: API forwarding support from zkBrokers to the controller **Changes** * Enable `EnvelopeRequest` to support zkBroker to zkController forwarding. * Changes to `BrokerToControllerChannelManager`, which we use in every broker to maintain a channel to the controller node. This node and security protocol to connect to the node can keep changing during zk -> kraft migration. Also, added support to reinitialize the request thread used in `BrokerToControllerChannelManager` when the controller switches from zkBroker to kraftController and vice-versa. * Other peripheral changes required to support the above changes. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org