代码拉取完成，页面将自动刷新
修改.env文件中配置的变量为自定义内容，如安装的命名空间、helm实例名称、char版本号等（可选）。
bash install.sh
bash status.sh
1. 启动临时 Pod
kubectl run my-kafka-cluster-client --rm --tty -i --restart='Never' --image docker.io/bitnami/kafka:4.0.0-debian-12-r5 --namespace kafka --command -- bash
2. 创建一个测试topic
kafka-topics.sh \
--create \
--bootstrap-server my-kafka-cluster:9092 \
--topic test_topic \
--partitions 6 \
--replication-factor 3
3. 启动生产者发送消息
kafka-console-producer.sh \
--bootstrap-server my-kafka-cluster:9092 \
--topic test_topic
4. 启动消费者接收消息
kafka-console-consumer.sh \
--bootstrap-server my-kafka-cluster:9092 \
--topic test_topic \
--from-beginning
5. k8s 内部访问 Kafka 实例
# 方式一：<service>.<namespace>.svc.cluster.local:9092
my-kafka-cluster.kafka.svc.cluster.local:9092
# 方式二：<pod>.<headless-service>.<namespace>.svc.cluster.local:9092
my-kafka-cluster-controller-0.my-kafka-cluster-controller-headless.kafka.svc.cluster.local:9092
my-kafka-cluster-controller-1.my-kafka-cluster-controller-headless.kafka.svc.cluster.local:9092
my-kafka-cluster-controller-2.my-kafka-cluster-controller-headless.kafka.svc.cluster.local:9092
1. 访问prometheus的/targets页面，查看kafka-exporter是否正常 scrape metrics
2. 访问grafana并导入面板7589，查看kafka-exporter的dashboard是否正常显示。
修改.env或install.sh文件中的内容，后重新执行install.sh脚本即可。
1. 执行卸载脚本
bash uninstall.sh
2. （可选）删除pvc
# 加载变量
source .env
# 查看pvc
kubectl get pvc -n ${NAMESPACE}
# 删除pvc（可能有多个pvc要删除）
kubectl delete pvc [pvc名称] -n ${NAMESPACE}
更详细的教程请查看：K8s采用Helm部署kafka-cluster
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手