kafka manager

yahoo出品的kafka管理工具，git地址https://github.com/yahoo/kafka-manager。

手动打包

kafka-manager用scala编写，需要使用sbt进行打包。sbt环境配置这里不详细介绍，但为加快依赖包下载速度，可以修改project/plugins.sbt，增加或修改resolvers。

1
2
3
// The Typesafe repository
// resolvers += "Typesafe repository" at "http://repo.typesafe.com/typesafe/releases/"
resolvers += "sonatype" at "https://oss.sonatype.org/content/repositories/public/"

然后使用./sbt clean dist进行打包，打包后的zip包在target/universal/下。

也可以直接下载我打包好的zip包:

配置修改

解压后启动前需要进行一些设置：

  1. 修改conf/application.conf中kafka-manager.zkhosts为你自己的zookeeper地址，此zk地址是kafka-manager使用的，用来保存一些kafka-manager的状态等。

    多个zk时用逗号分隔，

    1
    kafka-manager.zkhosts="my.zookeeper.host.com:2181,other.zookeeper.host.com:2181"

  2. 更改日志目录，修改conf/logback.xml中name为FILE的appender。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
      <!-- <file>${application.home}/logs/application.log</file> -->
      <encoder>
         <pattern>%date - [%level] - from %logger in %thread %n%message%n%xException%n</pattern>
      </encoder>
      <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
          <fileNamePattern>logs/application.%d{yyyy-MM-dd}.log</fileNamePattern>
          <maxHistory>5</maxHistory>
          <totalSizeCap>5GB</totalSizeCap>
      </rollingPolicy>
    </appender>

启动

指定java home和端口启动。

1
/bin/kafka-manager -java-home /usr/java/jdk1.8.0_66 -Dhttp.port=8909