kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated (9660ecd -> 6c0aed2)
Date Fri, 18 Oct 2019 05:54:56 GMT
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


Mime
View raw message