Kafka Web Console安装和使用
apache kafka中国社区QQ群:162272557Kafka Web Console是kafka的开源web监控程序.
功能介绍如下:
- brokers列表
- 连接kafka的zk集群列表
- 所有topic列表，操作相应topic可以浏览查看相应message生产和消费流量图.
1.下载Kafka Web Console
Kafka Web Console2.安装sbt
a. centos : yum install sbt b. ubuntu : apt-get install sbt3.配置Kafka Web Console
a.增加数据库依赖包(mysql)，解压kafka-web-console.tar.gz,进入目录cd kafka-web-console 编辑文件vim build.sbt 增加mysql配置： ...... libraryDependencies ++= Seq(jdbc,
cache,
"org.squeryl" % "squeryl_2.10" % "0.9.5-6",
"com.twitter" % "util-zk_2.10" % "6.11.0",
"com.twitter" % "finagle-core_2.10" % "6.15.0",
"org.apache.kafka" % "kafka_2.10" % "0.8.1",
"org.quartz-scheduler" % "quartz" % "2.2.1",
"mysql" % "mysql-connector-java" % "5.1.9"
exclude("javax.jms", "jms")
exclude("com.sun.jdmk", "jmxtools")
exclude("com.sun.jmx", "jmxri")
)
.......
4.配置mysql的jdbc驱动
vim application.conf 增加代码如下:.......
db.default.driver=com.mysql.jdbc.Driver
db.default.url="jdbc:mysql://192.168.2.105:3306/mafka?useUnicode=true&characterEncoding=UTF8&connectTimeout=5000&socketTimeout=10000"
db.default.user=xxx
db.default.password=xxx
.......
5.执行sql语句(如下绿色选框所示)
6.编译
lizhitao@localhost:~$ sbt package打包编译时会从官网上下载很多jar，由于网络原因，所以很慢，需要耐心等待。 注意:下载的jar是隐藏的，在cd ~/.ivy2 目录(相应子目录)下可以看到所有jar. ivy2所有jar包百度云下载 ivy2所有jar包下载
7.运行
lizhitao@localhost:~$ sbt run