本节重点介绍 :
检查kafka
- zookeeper启动应该listen 9309端口
检查jmx_exporter指标暴露的情况
kafka创建 topic
- 使用 kafka-topics.sh 创建 topic test和hello
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic Hello
查看 topic 列表：
bin/kafka-topics.sh --list --zookeeper localhost:2181
产生消息
- 使用 kafka-console-producer.sh 发送消息：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
bin/kafka-console-consumer.sh -bootstrap-server localhost:9092 --topic aggrin --from-beginning
消费消息
- 使用 kafka-console-consumer.sh 接收消息并在终端打印：
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
查看描述 topics 信息
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
本节重点总结 :
- jmx_exporter简介
- 监控kafka和zookeeper 的jmx
- 通过启动的java应用的时候将 jmx_prometheus_javaagent-0.16.0.jar注入进去
