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 9be36a4cd36 KAFKA-14729: The kafakConsumer pollForFetches(timer)
method takes up a lot of cpu due to the abnormal exit of the heartbeat thread
(#13270)
add ea30ec4b562 KAFKA-14590: Move DelegationTokenCommand to tools (#13172)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/admin/MockAdminClient.java | 91 +++++-
.../scala/kafka/admin/DelegationTokenCommand.scala | 224 ---------------
.../kafka/admin/DelegationTokenCommandTest.scala | 146 ----------
.../apache/kafka/tools/DelegationTokenCommand.java | 308 +++++++++++++++++++++
.../kafka/tools/DelegationTokenCommandTest.java | 110 ++++++++
5 files changed, 501 insertions(+), 378 deletions(-)
delete mode 100644 core/src/main/scala/kafka/admin/DelegationTokenCommand.scala
delete mode 100644
core/src/test/scala/unit/kafka/admin/DelegationTokenCommandTest.scala
create mode 100644
tools/src/main/java/org/apache/kafka/tools/DelegationTokenCommand.java
create mode 100644
tools/src/test/java/org/apache/kafka/tools/DelegationTokenCommandTest.java
