kubernetes安装kafka
kubernetes安装kafka
全栈程序员站长
发布于 2021-05-19 16:27:49
发布于 2021-05-19 16:27:49
代码可运行
运行总次数：0
代码可运行
使用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=10000retention.ms=10000设定消息过期时间为10秒，过期后消息会自动删除
删除topic
kafka-topics.sh --delete --topic test --zookeeper kafka-zookeeper.default.svc.cluster.local:2181发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/100333.html原文链接：
本文参与 腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录
腾讯云开发者
