[ https://issues.apache.org/jira/browse/KAFKA-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703163#comment-14703163 ]
ASF GitHub Bot commented on KAFKA-2411: --------------------------------------- GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/151 KAFKA-2411; remove usage of blocking channel You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka kafka-2411-remove-usage-of-blocking-channel Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/151.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #151 ---- commit dbcde7e828a250708752866c4610298773dea006 Author: Ismael Juma <ism...@juma.me.uk> Date: 2015-08-19T13:30:35Z Introduce `ChannelBuilders.create` and use it in `ClientUtils` and `SocketServer` commit 6de8b9b18c6bfb67e72a4fccc10768dff15098f8 Author: Ismael Juma <ism...@juma.me.uk> Date: 2015-08-19T14:22:55Z Use `Selector` instead of `BlockingChannel` for controlled shutdown commit da7a980887ab2b5d007ddf80c3059b6619d52f99 Author: Ismael Juma <ism...@juma.me.uk> Date: 2015-08-19T14:23:11Z Use `Selector` instead of `BlockingChannel` in `ControllerChannelManager` ---- > remove usage of BlockingChannel in the broker > --------------------------------------------- > > Key: KAFKA-2411 > URL: https://issues.apache.org/jira/browse/KAFKA-2411 > Project: Kafka > Issue Type: Sub-task > Components: security > Reporter: Jun Rao > Assignee: Ismael Juma > Fix For: 0.8.3 > > > In KAFKA-1690, we are adding the SSL support at Selector. However, there are > still a few places where we use BlockingChannel for inter-broker > communication. We need to replace those usage with Selector/NetworkClient to > enable inter-broker communication over SSL. Specially, BlockingChannel is > currently used in the following places. > 1. ControllerChannelManager: for the controller to propagate metadata to the > brokers. > 2. KafkaServer: for the broker to send controlled shutdown request to the > controller. > 3. -AbstractFetcherThread: for the follower to fetch data from the leader > (through SimpleConsumer)- moved to KAFKA-2440 -- This message was sent by Atlassian JIRA (v6.3.4#6332)