跳至内容
Wiki@桩白墨
用户工具
登录
站点工具
搜索
工具
显示页面
修订记录
反向链接
最近更改
媒体管理器
网站地图
登录
>
最近更改
媒体管理器
网站地图
您的足迹:
cmd:kafka
本页面只读。您可以查看源文件,但不能更改它。如果您觉得这是系统错误,请联系管理员。
[[https://www.cnblogs.com/xiaodf/p/6093261.html|Kafka Shell基本命令(包括topic的增删改查)]] ===== 启动 ===== === 启动zk === <code> bin/zookeeper-server-start.sh -daemon config/zookeeper.properties </code> === 启动kafka === <code> bin/kafka-server-start.sh config/server.properties </code> ===== topic管理 ===== === 创建topic === 创建单分区单副本的 topic test <code> bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test </code> === 查看 topic 列表 === <code> bin/kafka-topics.sh --list --zookeeper localhost:2181 </code> === 查看指定 topic 信息 === <code> bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test </code> ===== 生产与消费 ===== === 生产消息 === <code> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test </code> === 消费消息 === <code> bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning # 如果上面不管用的话 bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning </code>
cmd/kafka.txt
· 最后更改: 2021/02/07 13:05 由
plough
页面工具
显示页面
修订记录
反向链接
回到顶部