1)查看当前集群中已存在的主题topic
bin/kafka-topics.sh --zookeeper hd09:2181 --list
2)创建topic
bin/kafka-topics.sh --zookeeper hd09-01:2181 --create --replication-facto r 3 --partitions 1 --topic guan
--zookeeper 连接zk集群 --create 创建 --replication-factor 副本 --partitions 分区 --topic 主题名
3)删除主题
bin/kafka-topics.sh --zookeeper hd09-01:2181 --delete --topic guan
4)发送消息 生产者启动:
bin/kafka-console-producer.sh --broker-list hd09-01:9092 --topic guan
消费者启动:
bin/kafka-console-consumer.sh --bootstrap-server hd09-01:9092 --topic guan --from-beginning
5)查看主题详细信息
bin/kafka-topics.sh --zookeeper hd09-01:2181 --describe --topic guan
扫码关注腾讯云开发者
领取腾讯云代金券
Copyright © 2013 - 2025 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号:粤B2-20090059 深公网安备号 44030502008569
腾讯云计算(北京)有限责任公司 京ICP证150476号 | 京ICP备11018762号 | 京公网安备号11010802020287
Copyright © 2013 - 2025 Tencent Cloud.
All Rights Reserved. 腾讯云 版权所有