Kafka命令行操作

编程那点事

发布于 2023-02-25 16:04:25

2210

发布于 2023-02-25 16:04:25

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

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2019-03-01，如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

登录后参与评论

0 条评论

热度