kafka-manager

kafka-manager

• 介绍
  Kafka集群管理工具主要支持以下几个功能：
  1、管理几个不同的集群；
  2、很容易地检查集群的状态(topics, brokers, 副本的分布, 分区的分布)；
  3、选择副本；
  4、产生分区分配(Generate partition assignments)基于集群的当前状态；
  5、重新分配分区。
• 安装(centos)
  • 源码：https://github.com/yahoo/kafka-manager
  • 安装sbt

    curl https://bintray.com/sbt/rpm/rpm > bintray-sbt-rpm.repo
    mv bintray-sbt-rpm.repo /etc/yum.repos.d/
    yum install sbt
    

  • 打包
    生成的zip包会在kafka-manager/target/universal 下面
    注意：最新版kafka-manager需要jdk1.8，启动时可以配置参数指定jdk运行

    git clone https://github.com/yahoo/kafka-manager
    cd kafka-manager
    sbt clean dist
    

  • 修改配置
    修改conf/application.conf，修改kafka-manager.zkhosts=<kafka在zookeeper的url>
  • 启动
    bin/kafka-manager -Dconfig.file=./conf/application.conf -java-home /usr/java/jdk1.8.0_11/ -Dhttp.port=9099 &