kubernetes安装kafka

helm install kafka bitnami/kafka

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

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

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

kafka-configs.sh --bootstrap-server 10.108.77.12:2181 --describe --entity-type topics --entity-name test

kafka-configs.sh --bootstrap-server kafka-zookeeper.default.svc.cluster.local:2181 --entity-type topics --entity-name test --alter --add-config retention.ms=10000

kafka-topics.sh --delete --topic test --zookeeper kafka-zookeeper.default.svc.cluster.local:2181