赞
踩
实际使用中,部署好kafka集群后,需要管理集群,那么一个好的web控制台就显得尤为重要了。
Apache Kafka UI 是一个简单的工具,可让您的数据流可观察,帮助更快地发现和解决问题并提供最佳性能。其轻量级仪表板可以轻松跟踪 Kafka 集群的关键指标 - 代理、主题、分区、生产和消耗。
直接上部署代码,亲测可用
https://github.com/provectus/kafka-ui
kafka-ui-cm
注意,如果是想管理多个 kafka 集群,则需要配置多个集群信息,并在配置文件中不同的索引号以示区分。例如 _0,_1,_2,如下图所示
- ---
- apiVersion: v1
- data:
- ANNOTATION: 'DYNAMIC_CONFIG_ENABLED: true'
- AUTH_TYPE: LOGIN_FORM
- KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: ${实例0的kafka地址}
- KAFKA_CLUSTERS_0_NAME: ${kafka-0的名字}
- KAFKA_CLUSTERS_0_PROPERTIES_SECURITY_PROTOCOL: SSL
- KAFKA_CLUSTERS_1_BOOTSTRAPSERVERS: ${实例1的kafka地址}
- KAFKA_CLUSTERS_1_NAME: ${kafka-1的名字}
- KAFKA_CLUSTERS_1_PROPERTIES_SECURITY_PROTOCOL: SSL
- SPRING_SECURITY_USER_NAME: admin
- SPRING_SECURITY_USER_PASSWORD: ${设置管理员密码}
- TZ: UTC
- kind: ConfigMap
- metadata:
- labels:
- app: kafka-ui-cm
- name: kafka-ui-cm
- namespace: xxx
-
kafka-ui
- ---
- apiVersion: apps/v1
- kind: Deployment
- metadata:
- annotations: {}
- labels:
- k8s.kuboard.cn/name: kafka-ui
- name: kafka-ui
- namespace: xxx
- spec:
- progressDeadlineSeconds: 600
- replicas: 1
- revisionHistoryLimit: 10
- selector:
- matchLabels:
- app: kafka-ui
- strategy:
- rollingUpdate:
- maxSurge: 25%
- maxUnavailable: 25%
- type: RollingUpdate
- template:
- metadata:
- annotations:
- kubectl.kubernetes.io/restartedAt: '2023-11-28T16:21:38+08:00'
- creationTimestamp: null
- labels:
- app: kafka-ui
- spec:
- containers:
- - envFrom:
- - configMapRef:
- name: kafka-ui-cm
- image: 'provectuslabs/kafka-ui:latest'
- imagePullPolicy: Always
- name: kafka-ui
- resources: {}
- terminationMessagePath: /dev/termination-log
- terminationMessagePolicy: File
- dnsPolicy: ClusterFirst
- restartPolicy: Always
- schedulerName: default-scheduler
- securityContext: {}
- terminationGracePeriodSeconds: 30
-
- ---
- apiVersion: v1
- kind: Service
- metadata:
- annotations: {}
- labels:
- app: kafka-ui
- name: kafka-ui
- namespace: xxx
- spec:
- externalTrafficPolicy: Cluster
- internalTrafficPolicy: Cluster
- ipFamilies:
- - IPv4
- ipFamilyPolicy: SingleStack
- ports:
- - nodePort: 32204
- port: 8080
- protocol: TCP
- targetPort: 8080
- selector:
- app: kafka-ui
- sessionAffinity: None
- type: NodePort
-
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。