【Kafka之kafka-manager监控使用示例】

[root@node1 opt]# ls

collectd         flume1.6       influxdb              nagios-plugins-1.4.13  Python-2.6.6.tgz                

  yum-3.2.26.tar.gz  elasticsearch-2.0.0-rc1         gnu            kafka_2.10-0.9.0.1                  

 openssl-1.0.0e         soft         zookeepe346  elasticsearch-2.1.1             grafana-2.5.0  

kafka-web-console-2.1.0-SNAPSHOT      ORCLfmap               storm096       zookeeper.out

elasticsearch-jdbc-2.2.0.0      hadoop         kafka-web-console-2.1.0-SNAPSHOT.zip  path                   stormTest.jar  elasticsearch-jdbc-2.2.0.0.zip  hadoop_data    mq       php-5.4.10   wget-log

es5.0          httpd-2.2.23   nagios       Python-2.6.6     yum-3.2.22-40.el5.centos.noarch.rpm

[root@node1 opt]# cd zookeepe346/bin/

[root@node1 bin]# ./zkServer.sh start

JMX enabled by default

Using config: /opt/zookeepe346/bin/../conf/zoo.cfg

Starting zookeeper ... STARTED

[root@node1 bin]# cd ../../kafka_2.10-0.9.0.1/

[root@node1 kafka_2.10-0.9.0.1]# cd bin/

 

[root@node1 opt]# ls

collectd        flume1.6       influxdb         mq          php-5.4.10     wget-log   elasticsearch-2.0.0-rc1         gnu            kafka_2.10-0.9.0.1         nagios     Python-2.6.6      yum-3.2.22-40.el5.centos.noarch.rpm

elasticsearch-2.1.1   grafana-2.5.0  kafka-manager-1.3.0.4.zip             nagios-plugins-1.4.13  Python-2.6.6.tgz  yum-3.2.26.tar.gz  elasticsearch-jdbc-2.2.0.0      hadoop         kafka-manager-1.3.3.4.zip             openssl-1.0.0e         soft     zookeepe346   elasticsearch-jdbc-2.2.0.0.zip  hadoop_data    

kafka-web-console-2.1.0-SNAPSHOT      ORCLfmap               storm096          zookeeper.out

es5.0         httpd-2.2.23   kafka-web-console-2.1.0-SNAPSHOT.zip  path    stormTest.jar

 

[root@node1 bin]# ./kafka-server-start.sh ../config/server.properties  &

[1] 3653

 

[root@node1 opt]# unzip kafka-manager-1.3.3.4.zip

 

[root@node1 kafka-manager-1.3.3.4]# cd bin/

[root@node1 bin]# ls

kafka-manager  kafka-manager.bat

[root@node1 bin]# sh kafka-manager

Exception in thread "main" java.lang.UnsupportedClassVersionError: com/typesafe/config/ConfigException : Unsupported major.minor version 52.0  -->修改JDK版本

        at java.lang.ClassLoader.defineClass1(Native Method)

        at java.lang.ClassLoader.defineClass(ClassLoader.java:800)

        at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)

        at java.net.URLClassLoader.defineClass(URLClassLoader.java:449)

        at java.net.URLClassLoader.access$100(URLClassLoader.java:71)

        at java.net.URLClassLoader$1.run(URLClassLoader.java:361)

        at java.net.URLClassLoader$1.run(URLClassLoader.java:355)

        at java.security.AccessController.doPrivileged(Native Method)

        at java.net.URLClassLoader.findClass(URLClassLoader.java:354)

        at java.lang.ClassLoader.loadClass(ClassLoader.java:425)

        at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)

        at java.lang.ClassLoader.loadClass(ClassLoader.java:358)

        at play.core.server.ProdServerStart$.readServerConfigSettings(ProdServerStart.scala:81)

        at play.core.server.ProdServerStart$.start(ProdServerStart.scala:42)

        at play.core.server.ProdServerStart$.main(ProdServerStart.scala:27)

        at play.core.server.ProdServerStart.main(ProdServerStart.scala)

[root@node1 bin]# cat kafka-manager

[root@node1 bin]# vi application.conf  -->配置ZK

[root@node1 bin]# cat ../conf/application.conf 

 

# Copyright 2015 Yahoo Inc. Licensed under the Apache License, Version 2.0

# See accompanying LICENSE file.

 

# This is the main configuration file for the application.

# ~~~~~

 

# Secret key

# ~~~~~

# The secret key is used to secure cryptographics functions.

# If you deploy your application to several instances be sure to use the same key!

play.crypto.secret="^<csmm5Fx4d=r2HEX8pelM3iBkFVv?k[mc;IZE<_Qoq8EkX_/7@Zt6dP05Pzea3U"

play.crypto.secret=${?APPLICATION_SECRET}

 

# The application languages

# ~~~~~

play.i18n.langs=["en"]

 

play.http.requestHandler = "play.http.DefaultHttpRequestHandler"

play.http.context = "/"

play.application.loader=loader.KafkaManagerLoader

 

kafka-manager.zkhosts="192.168.8.131:2181"

#kafka-manager.zkhosts=${?ZK_HOSTS}

pinned-dispatcher.type="PinnedDispatcher"

pinned-dispatcher.executor="thread-pool-executor"

application.features=["KMClusterManagerFeature","KMTopicManagerFeature","KMPreferredReplicaElectionFeature","KMReassignPartitionsFeature"]

 

akka {

  loggers = ["akka.event.slf4j.Slf4jLogger"]

  loglevel = "INFO"

}

 

 

basicAuthentication.enabled=false

basicAuthentication.username="admin"

basicAuthentication.password="password"

basicAuthentication.realm="Kafka-Manager"

 

 

kafka-manager.consumer.properties.file=${?CONSUMER_PROPERTIES_FILE}

[root@node1 bin]# 

 

[root@node1 bin]# sh kafka-manager