This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from a619c6bb952 MINOR; Remove cast for Records' slice (#19661)
add f01e5aa9649 KAFKA-19145 Move LeaderEndPoint to Server module (#19630)
No new revisions were added by this update.
Summary of changes:
.../main/java/kafka/server/TierStateMachine.java | 16 +--
.../kafka/server/AbstractFetcherManager.scala | 4 +-
.../scala/kafka/server/AbstractFetcherThread.scala | 156 +++++++--------------
.../main/scala/kafka/server/LeaderEndPoint.scala | 117 ----------------
.../scala/kafka/server/LocalLeaderEndPoint.scala | 57 ++++----
.../scala/kafka/server/RemoteLeaderEndPoint.scala | 43 +++---
.../kafka/server/ReplicaAlterLogDirsManager.scala | 3 +-
.../kafka/server/ReplicaAlterLogDirsThread.scala | 2 +
.../scala/kafka/server/ReplicaFetcherManager.scala | 3 +-
.../scala/kafka/server/ReplicaFetcherThread.scala | 1 +
.../server/DynamicBrokerReconfigurationTest.scala | 3 +-
.../kafka/server/LocalLeaderEndPointTest.scala | 48 ++++---
.../kafka/server/RemoteLeaderEndPointTest.scala | 25 ++--
.../kafka/server/AbstractFetcherManagerTest.scala | 44 +++---
.../kafka/server/AbstractFetcherThreadTest.scala | 57 ++++----
.../unit/kafka/server/MockFetcherThread.scala | 3 +-
.../unit/kafka/server/MockLeaderEndPoint.scala | 37 +++--
.../unit/kafka/server/MockTierStateMachine.scala | 9 +-
.../server/ReplicaAlterLogDirsThreadTest.scala | 85 ++++++-----
.../kafka/server/ReplicaFetcherThreadTest.scala | 52 +++----
.../unit/kafka/server/ReplicaManagerTest.scala | 9 +-
.../unit/kafka/server/TierStateMachineTest.scala | 9 +-
.../jmh/fetcher/ReplicaFetcherThreadBenchmark.java | 12 +-
.../org/apache/kafka/server/LeaderEndPoint.java | 114 +++++++++++++++
.../apache/kafka/server/PartitionFetchState.java | 98 +++++++++++++
.../java/org/apache/kafka/server/ReplicaFetch.java | 13 +-
.../{package-info.java => ReplicaState.java} | 22 ++-
.../apache/kafka/server/ResultWithPartitions.java | 14 +-
28 files changed, 588 insertions(+), 468 deletions(-)
delete mode 100644 core/src/main/scala/kafka/server/LeaderEndPoint.scala
create mode 100644
server/src/main/java/org/apache/kafka/server/LeaderEndPoint.java
create mode 100644
server/src/main/java/org/apache/kafka/server/PartitionFetchState.java
copy
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/OffsetCheckpoints.java
=> server/src/main/java/org/apache/kafka/server/ReplicaFetch.java (76%)
copy server/src/main/java/org/apache/kafka/server/{package-info.java =>
ReplicaState.java} (73%)
copy core/src/main/java/kafka/server/ReplicaQuota.java =>
server/src/main/java/org/apache/kafka/server/ResultWithPartitions.java (83%)
