安装kafka 启动3个节点

kubectl create ns kafka
helm repo add bitnami https://charts.bitnami.com/bitnami
helm install kafka -n kafka bitnami/kafka --set replicaCount=3

安装测试程序

kubectl run kafka-client --restart='Never' --image docker.io/bitnami/kafka:2.7.0-debian-10-r109 --namespace kafka --command -- sleep infinity

使用生产者

kubectl exec --tty -i kafka-client --namespace kafka -- bash

        kafka-console-producer.sh \            
            --broker-list kafka-0.kafka-headless.kafka.svc.cluster.local:9092 \
            --topic test

使用消费者

kubectl exec --tty -i kafka-client --namespace kafka -- bash

kafka-console-consumer.sh \            
            --bootstrap-server kafka.kafka.svc.cluster.local:9092 \
            --topic test \
            --from-beginning