[kafka] branch trunk updated (82d5720aae7 -> 322ac86ba28)

[sh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

showuon pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from 82d5720aae7 KAFKA-14253 - More informative logging (#13253)
     add 322ac86ba28 KAFKA-14706: Move/rewrite ShutdownableThread to server-common module. (#13234)

No new revisions were added by this update.

Summary of changes:
 build.gradle                                       |   2 +-
 checkstyle/import-control-core.xml                 |   1 +
 .../scala/kafka/common/InterBrokerSendThread.scala |   8 +-
 .../common/ZkNodeChangeNotificationListener.scala  |   5 +-
 .../controller/ControllerChannelManager.scala      |   6 +-
 .../kafka/controller/ControllerEventManager.scala  |  11 +-
 core/src/main/scala/kafka/log/LogCleaner.scala     |   6 +-
 .../scala/kafka/log/remote/RemoteIndexCache.scala  |   4 +-
 core/src/main/scala/kafka/raft/RaftManager.scala   |  11 +-
 .../kafka/raft/TimingWheelExpirationService.scala  |   6 +-
 .../scala/kafka/server/AbstractFetcherThread.scala |   7 +-
 .../scala/kafka/server/ClientQuotaManager.scala    |   3 +-
 .../main/scala/kafka/server/DelayedOperation.scala |   2 +-
 .../server/FinalizedFeatureChangeListener.scala    |   8 +-
 .../main/scala/kafka/server/ReplicaManager.scala   |   2 +-
 .../kafka/tools/ReplicaVerificationTool.scala      |   6 +-
 .../main/scala/kafka/tools/TestRaftServer.scala    |   6 +-
 .../scala/kafka/utils/ShutdownableThread.scala     | 113 ----------------
 .../kafka/api/AbstractConsumerTest.scala           |   3 +-
 .../integration/kafka/api/ConsumerBounceTest.scala |   3 +-
 .../kafka/api/TransactionsBounceTest.scala         |   3 +-
 .../server/DynamicBrokerReconfigurationTest.scala  |   5 +-
 .../other/kafka/TestPurgatoryPerformance.scala     |   6 +-
 .../server/ReplicaManagerConcurrencyTest.scala     |  11 +-
 .../unit/kafka/utils/ShutdownableThreadTest.scala  |   2 +-
 .../kafka/server/util/ShutdownableThread.java      | 146 +++++++++++++++++++++
 26 files changed, 222 insertions(+), 164 deletions(-)
 delete mode 100644 core/src/main/scala/kafka/utils/ShutdownableThread.scala
 create mode 100644 server-common/src/main/java/org/apache/kafka/server/util/ShutdownableThread.java