You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2021/02/08 20:09:02 UTC
[kafka] branch trunk updated (8c72842 -> 1d3e293)
This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 8c72842 MINOR: remove an unnecessary explicit type argument (#9982)
add 1d3e293 MINOR: Add ClusterTool as specified in KIP-631 (#10047)
No new revisions were added by this update.
Summary of changes:
bin/{kafka-log-dirs.sh => kafka-cluster.sh} | 2 +-
build.gradle | 1 +
.../kafka/clients/admin/MockAdminClient.java | 25 ++++-
core/src/main/scala/kafka/tools/ClusterTool.scala | 125 +++++++++++++++++++++
.../TerseFailure.scala} | 12 +-
.../scala/unit/kafka/tools/ClusterToolTest.scala | 74 ++++++++++++
6 files changed, 231 insertions(+), 8 deletions(-)
copy bin/{kafka-log-dirs.sh => kafka-cluster.sh} (91%)
create mode 100644 core/src/main/scala/kafka/tools/ClusterTool.scala
copy core/src/main/scala/kafka/{common/LogCleaningAbortedException.scala => tools/TerseFailure.scala} (68%)
create mode 100644 core/src/test/scala/unit/kafka/tools/ClusterToolTest.scala