You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2020/12/22 02:22:26 UTC
[kafka] branch trunk updated (d3f19e4 -> eb9fe41)
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from d3f19e4 KAFKA-10825 ZooKeeper ISR manager (#9713)
add eb9fe41 KAFKA-10842; Use `InterBrokerSendThread` for raft's outbound network channel (#9732)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../kafka/common/requests/AbstractRequest.java | 3 -
.../common/requests/AbstractRequestResponse.java | 7 +-
.../kafka/common/requests/AbstractResponse.java | 3 -
.../kafka/clients/admin/KafkaAdminClientTest.java | 12 +-
.../scala/kafka/common/InterBrokerSendThread.scala | 55 +++--
.../TransactionMarkerChannelManager.scala | 33 +--
.../scala/kafka/raft/KafkaNetworkChannel.scala | 251 ++++++++-------------
.../main/scala/kafka/server/AlterIsrManager.scala | 67 ++++--
...cala => BrokerToControllerChannelManager.scala} | 182 ++++++++-------
.../scala/kafka/server/ForwardingManager.scala | 63 ++++--
core/src/main/scala/kafka/server/KafkaServer.scala | 52 +++--
.../main/scala/kafka/server/ReplicaManager.scala | 1 -
.../scala/kafka/tools/TestRaftRequestHandler.scala | 60 ++++-
.../main/scala/kafka/tools/TestRaftServer.scala | 8 +-
.../kafka/common/InterBrokerSendThreadTest.scala | 54 +++--
.../BrokerToControllerRequestThreadTest.scala | 153 ++++++++-----
.../TransactionMarkerChannelManagerTest.scala | 2 +-
.../unit/kafka/raft/KafkaNetworkChannelTest.scala | 57 ++---
.../unit/kafka/server/AlterIsrManagerTest.scala | 27 ++-
.../unit/kafka/server/ForwardingManagerTest.scala | 8 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 2 -
.../org/apache/kafka/raft/KafkaRaftClient.java | 99 ++++++--
.../java/org/apache/kafka/raft/LeaderState.java | 11 +-
.../java/org/apache/kafka/raft/NetworkChannel.java | 19 +-
.../org/apache/kafka/raft/RaftMessageQueue.java | 58 +++++
.../java/org/apache/kafka/raft/RaftRequest.java | 5 +
.../java/org/apache/kafka/raft/RequestManager.java | 18 +-
.../kafka/raft/internals/BlockingMessageQueue.java | 76 +++++++
.../org/apache/kafka/raft/KafkaRaftClientTest.java | 193 ++++++++--------
.../test/java/org/apache/kafka/raft/MockLog.java | 7 +
.../org/apache/kafka/raft/MockMessageQueue.java | 67 ++++++
.../org/apache/kafka/raft/MockNetworkChannel.java | 101 +++------
.../apache/kafka/raft/RaftClientTestContext.java | 96 +++++---
.../apache/kafka/raft/RaftEventSimulationTest.java | 81 ++++---
.../org/apache/kafka/raft/RequestManagerTest.java | 5 +-
.../raft/internals/BlockingMessageQueueTest.java | 59 +++++
37 files changed, 1215 insertions(+), 782 deletions(-)
rename core/src/main/scala/kafka/server/{BrokerToControllerChannelManagerImpl.scala => BrokerToControllerChannelManager.scala} (56%)
create mode 100644 raft/src/main/java/org/apache/kafka/raft/RaftMessageQueue.java
create mode 100644 raft/src/main/java/org/apache/kafka/raft/internals/BlockingMessageQueue.java
create mode 100644 raft/src/test/java/org/apache/kafka/raft/MockMessageQueue.java
create mode 100644 raft/src/test/java/org/apache/kafka/raft/internals/BlockingMessageQueueTest.java