本篇博主带来的是Kafka的两种监控软件。

[bigdata@hadoop002 module]$ mkdir kafka-offset-console
[bigdata@hadoop002 module]$ cd kafka-offset-console/[bigdata@hadoop002 kafka-offset-console]$ cp /opt/software/Kafka/KafkaOffsetMonitor-assembly-0.4.6-SNAPSHOT.jar ./[bigdata@hadoop002 kafka-offset-console]$ vim start.sh
#!/bin/bash
java -cp KafkaOffsetMonitor-assembly-0.4.6-SNAPSHOT.jar \
com.quantifind.kafka.offsetapp.OffsetGetterWeb \
--offsetStorage kafka \
--kafkaBrokers hadoop002:9092,hadoop003:9092,hadoop004:9092 \
--kafkaSecurityProtocol PLAINTEXT \
--zk hadoop002:2181,hadoop003:2181,hadoop004:2181 \
--port 8086 \
--refresh 10.seconds \
--retain 2.days \
--dbName offsetapp_kafka &
// 变成和执行性文件
[bigdata@hadoop002 kafka-offset-console]$ chmod +x start.sh[bigdata@hadoop002 kafka-offset-console]$ mkdir mobile-log[bigdata@hadoop002 kafka-offset-console]$ ./start.sh 
如果出现下图就代表成功了

下面可以进行一些简单的操作


[bigdata@hadoop002 Kafka]$ unzip kafka-manager-1.3.3.15.zip -d /opt/module/[bigdata@hadoop002 kafka-manager-1.3.3.15]$ vim conf/application.conf
kafka-manager.zkhosts="kafka-manager-zookeeper:2181"
修改为:
kafka-manager.zkhosts="hadoop002:2181,hadoop003:2181,hadoop004:2181"[bigdata@hadoop002 bin]$ chmod +x kafka-manager
[bigdata@hadoop002 kafka-manager-1.3.3.15]$ bin/kafka-manager
// 修改端口号
[bigdata@hadoop002 kafka-manager-1.3.3.15]$ bin/kafka-manager -Dhttp.port=9090
出现上图即为成功




剩下的一些具体操作可以自行摸索,或者等到博主有时间会专门出一期教程!
本次的分享就到这里了