使用helm3安装
helm install kafka bitnami/kafka
查看
使用kafka-client做测试
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
输入hello word ，测试消息通信
查看topic状态
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
retention.ms=10000设定消息过期时间为10秒，过期后消息会自动删除
删除topic
kafka-topics.sh --delete --topic test --zookeeper kafka-zookeeper.default.svc.cluster.local:2181
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
发布者：全栈程序员-用户IM，转载请注明出处：https://javaforall.cn/100333.html原文链接：https://javaforall.cn
【正版授权，激活自己账号】： Jetbrains全家桶Ide使用，1年售后保障，每天仅需1毛
【官方授权 正版激活】： 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...