https://blog.frognew.com/2019/07/kafka-manager.htmlhtml
前面咱们已经在k8s上使用incubator/kafka
chart部署了Kafka。本篇来聊聊kafka的管理和监控。 关于kafka的监控方案有不少:git
Prometheus + kafka-prometheus-jmx-exporter
的监控方案,这个也是incubator/kafka
中支持的监控方案,默认使用helm部署kafka是没有开启,可经过prometheus.kafka.enabled
开启,这里先不开启,准备在以后的内容中介绍Prometheus + kafka-prometheus-jmx-exporter
Helm的官方repo中已经提供了Kafka Manager的Chart。github
建立kafka-manager-values.yaml
:app
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 |
image: repository: zenko/kafka-manager tag: 1.3.3.22 zkHosts: kafka-zookeeper:2181 basicAuth: enabled: true username: admin password: admin ingress: enabled: true hosts: - kafka.frognew.com tls: - secretName: frognew-com-tls-secret hosts: - kafka.frognew.com |
使用helm部署kafka-manager:spa
1 |
helm install --name kafka-manager --namespace kafka -f kafka-manager-values.yaml stable/kafka-manager |
安装完成后,确认kafka-manager的Pod已经正常启动:code
1 2 3 |
kubectl get pod -n kafka -l app=kafka-manager NAME READY STATUS RESTARTS AGE kafka-manager-5d974b7844-bl7k4 1/1 Running 0 5m47s |
使用https://kafka.frognew.com打开kafka-manager
的页面,将咱们以前在k8s上部署的kafka集群以名称为test,并配置Cluster Zookeeper Hosts
为kafka-zookeeper:2181
,便可将前面部署的kafka集群归入kafka-manager
管理当中。htm