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 9660ecd MINOR: Fix JavaDoc warning (#7546)
add 6c0aed2 KAFKA-8834; Add reassignment metrics and distinguish URPs
(KIP-352) (#7361)
No new revisions were added by this update.
Summary of changes:
core/src/main/scala/kafka/admin/TopicCommand.scala | 50 ++++++--
core/src/main/scala/kafka/cluster/Partition.scala | 70 ++++++++---
.../scala/kafka/server/AbstractFetcherThread.scala | 3 +-
.../src/main/scala/kafka/server/DelayedFetch.scala | 3 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 11 +-
.../scala/kafka/server/KafkaRequestHandler.scala | 65 +++++++---
.../kafka/server/ReplicaAlterLogDirsThread.scala | 3 +-
.../scala/kafka/server/ReplicaFetcherThread.scala | 9 +-
.../main/scala/kafka/server/ReplicaManager.scala | 34 ++++--
.../kafka/server/DelayedFetchTest.scala | 2 +
.../admin/ReassignPartitionsClusterTest.scala | 66 ++---------
.../admin/TopicCommandWithAdminClientTest.scala | 52 +++++++-
.../unit/kafka/cluster/AbstractPartitionTest.scala | 96 +++++++++++++++
.../unit/kafka/cluster/AssignmentStateTest.scala | 126 ++++++++++++++++++++
.../scala/unit/kafka/cluster/PartitionTest.scala | 131 ++++++++++-----------
.../kafka/server/AbstractFetcherThreadTest.scala | 15 ++-
.../server/HighwatermarkPersistenceTest.scala | 4 +-
.../unit/kafka/server/IsrExpirationTest.scala | 4 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 84 +++++++++++--
.../kafka/server/ReplicaFetcherThreadTest.scala | 96 +++++++++++++--
.../kafka/server/ReplicaManagerQuotasTest.scala | 4 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 23 ++--
.../scala/unit/kafka/server/SimpleFetchTest.scala | 4 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 54 +++++++++
24 files changed, 788 insertions(+), 221 deletions(-)
create mode 100644
core/src/test/scala/unit/kafka/cluster/AbstractPartitionTest.scala
create mode 100644
core/src/test/scala/unit/kafka/cluster/AssignmentStateTest.scala
