Apache Kafka 入门 - Kafka-manager安装指南

1.下载最新的kafka-manager

地址：https://github.com/yahoo/kafka-manager/releases

 

2.下载安装kafka-manager要求的java版本

ps:检查系统环境path路径是否添加

 

3.下载安装kafka-manager要求scala版本

地址：https://www.scala-lang.org/download/

配置环境变量

运行环境	环境变量	值(example)
Unix	$SCALA_HOME	/usr/local/share/scala
	$PATH	$PATH:$SCALA_HOME/bin
Windows	%SCALA_HOME%	c:\Progra~1\Scala
	%PATH%	%PATH%;%SCALA_HOME%\bin

  

4.下载安装kafka-manager要求sbt

地址：https://www.scala-sbt.org/download.html

 1）修改sbt配置：

WINDOWS修改配置文件sbt-1.2.8\conf\sbtconfig.txt

LINUX修改配置文件sbt-1.2.8\conf\sbtopts

增加如下配置项

 

-Dsbt.override.build.repos=true
-Dsbt.log.format=true
-Dsbt.repository.config=/opt/sbt-1.2.8/conf/repositories #使用绝对路径
-Dsbt.global.base=/opt/sbt-1.2.8/project/.sbtboot
-Dsbt.boot.directory=/opt/sbt-1.2.8/project/.boot
-Dsbt.ivy.home=/opt/sbt-1.2.8/project/.ivy

 

 

 2）配置国内资源库：

新建conf\repositories文件：

 

[repositories]
local
aliyun-nexus: http://maven.aliyun.com/nexus/content/groups/public/  
ibiblio-maven: http://maven.ibiblio.org/maven2/
typesafe-ivy: https://dl.bintray.com/typesafe/ivy-releases/,[organization]/[module]/(scala_[scalaVersion]/)(sbt_[sbtVersion]/)[revision]/[type]s/[artifact](-[classifier]).[ext]
uk-repository: http://uk.maven.org/maven2/
jboss-repository: http://repository.jboss.org/nexus/content/groups/public/

osc: http://maven.oschina.net/content/groups/public/
typesafe: http://repo.typesafe.com/typesafe/ivy-releases/, [organization]/[module]/(scala_[scalaVersion]/)(sbt_[sbtVersion]/)[revision]/[type]s/[artifact](-[classifier]).[ext], bootOnly
sonatype-oss-releases
maven-central
sonatype-oss-snapshots

 ps:配置参考：http://www.scala-sbt.org/0.13.2/docs/Detailed-Topics/Library-Management.html#override-all-resolvers-for-all-builds

 

5.解压下载的 Kafka-manager

进入Kafka-manager目录，执行下面的命令：

 

> ./sbt clean dist

 

ps:如果之前从来没有用过Play框架，这个步骤会需要一定时间，主要是下载依赖的jar包，使用aliyun的私服可以让这个过程缩短很多。

命令执行完成后，在 target/universal 目录中会生产一个zip压缩包kafka-manager-2.0.0.0.zip。将压缩包拷贝到要部署的目录下解压。

在解压后修改配置文件./conf/application.conf，最主要的内容为：

 

#zookeeper地址
kafka-manager.zkhosts="localhost:12001" 

 配置为Kafka的 zookeeper 服务器。还可以通过环境变量ZK_HOSTS配置这个参数值。

 

ps：其他详细的配置信息参考官方文档：https://github.com/yahoo/kafka-manager

6.启动Kafka-manager

在解压的目录中，使用下面的命令启动Kafka-manager

 

> bin/kafka-manager

 默认情况下端口为9000，你还可以通过下面的命令指定配置文件和端口：

 

 

> bin/kafka-manager -Dconfig.file=/path/to/application.conf -Dhttp.port=8080

 后台启动方式：

 

 

nohup bin/kafka-manager -Dconfig.file=../conf/application.conf -Dhttp.port=8080

 如果没有配置Java的环境变量，还可以通过下面的方式指定Java8的目录：

 

 

> bin/kafka-manager -java-home /usr/local/oracle-java-8

 启动后，从浏览器打开localhost:8080，显示如下：

 

 

7.配置集群

点击【Cluster】>【Add Cluster】打开如下添加集群的配置界面:

 

其他broker的配置可以根据自己需要进行配置，默认情况下，点击【保存】时，会提示几个默认值为1的配置错误，需要配置为>=2的值。保存成功后，提示如下。

在集群界面显示了主题和Broker的个数，点击数字可以查看具体的信息。

同时在顶部多了好几个菜单，可以查看集群、Broker、主题等信息。