用户工具

站点工具


cmd:kafka

差别

这里会显示出您选择的修订版和当前版本之间的差别。

到此差别页面的链接

两侧同时换到之前的修订记录前一修订版
cmd:kafka [2021/02/07 13:05] – [topic管理] ploughcmd:kafka [Unknown date] (当前版本) – 移除 - 外部编辑 (Unknown date) 127.0.0.1
行 1: 行 1:
-[[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.1612674348.txt.gz · 最后更改: 2022/12/28 17:53 (外部编辑)

Donate Powered by PHP Valid HTML5 Valid CSS Driven by DokuWiki