[
https://issues.apache.org/jira/browse/KAFKA-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10842.
-------------------------------------
Resolution: Fixed
> Refactor raft outbound request channel
> --------------------------------------
>
> Key: KAFKA-10842
> URL: https://issues.apache.org/jira/browse/KAFKA-10842
> Project: Kafka
> Issue Type: Sub-task
> Reporter: Jason Gustafson
> Assignee: Jason Gustafson
> Priority: Major
>
> There are a few bugs in the current `KafkaNetworkChannel` implementation.
> Most of the problems are just features which haven't been implemented yet,
> such as timing out requests which are unable to be sent. Most of these issues
> are already addressed by `InterBrokerSendThread`. Since this is the class we
> are standardizing on, we should change the implementation here.
> We also want to address some shortcomings with the current network api used
> by the raft layer. Specifically we want to allow outbound IO to be done on a
> separate thread so that it does not block request handling. Additionally, we
> would like to leave the door more open for concurrent handling of inbound
> requests, which is not currently possible because all requests (inbound and
> outbound) are piped through the same `receive()` API.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
