kafka web console安裝
此文章參考了
http://blog.csdn.net/wuzhilon88/article/details/46300447
http://blog.csdn.net/hengyunabc/article/details/40431627
感謝兩位大神提供的資源幫助
Kafka Web Console是kafka的開源web監控程式.
功能介紹如下:
brokers列表
連線kafka的zk叢集列表
所有topic列表,操作相應topic可以瀏覽檢視相應message生產和消費流量圖.
1、準備
安裝sbt
1.下載Kafka Web Console
https://github.com/claudemamo/kafka-web-console
2.解壓到/opt下
$ unzip kafka-web-console-master.zip
$ cd kafka-web-console
3.修改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驅動
$
vi conf/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.編譯
- [email protected]:~$ sbt package
打包編譯時會從官網上下載很多jar,由於網路原因,所以很慢,需要耐心等待。
注意:下載的jar是隱藏的,在cd ~/.ivy2 目錄(相應子目錄)下可以看到所有jar.
ivy2所有jar包百度雲下載http://pan.baidu.com/s/1nuWhqxr
- [email protected]:~$ sbt run
也可以打包後期執行方便
$
sbt dist 這個命令生成可以釋出的包,在../target/universal目錄下。
解壓
- unzip kafka-web-console-2.1.0-SNAPSHOT.zip
- cd kafka-web-console-2.1.0-SNAPSHOT/bin
在編譯的過程中,可能會出現有些依賴包無法下載,如下錯誤:
01 |
[warn]
module not found: com.typesafe.play#sbt-plugin; 2.2 . 1 |
02 |
[warn]
==== typesafe-ivy-releases: tried |
03 |
[warn]
http: //repo.typesafe.com/typesafe/ivy-releases/ |
04 |
com.typesafe.play/sbt-plugin/scala_2. 9.2 /sbt_0. 12 / 2.2 . 1 /ivys/ivy.xml |
05 |
[warn]
==== sbt-plugin-releases: tried |
06 |
[warn]
http: //scalasbt.artifactoryonline.com/scalasbt/sbt-plugin-releases/ |
07 |
com.typesafe.play/sbt-plugin/scala_2. 9.2 /sbt_0. 12
|