首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >kafka常用的命令

kafka常用的命令

作者头像
用户5522200
发布2019-06-02 15:18:42
3500
发布2019-06-02 15:18:42
举报
文章被收录于专栏:lindalinda

1、启动zookeeper

# ./zkServer.sh start

2、查看zookeeper是否启动

# ps -ef |grep java

3、关闭zookeeper

# ./zkServer.sh stop

4、查看zookeeper的状态

# ./zkServer.sh status

5、启动kafka

# ./kafka-server-start.sh -daemon ../config/server.properties &

6、查看kafka是否启动

# ps -ef |grep kafka

7、关闭kafka

# ./kafka-server-stop.sh

8、创建topic

# ./kafka-topics.sh --create --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181 --replication-factor 3 --partitions 1 --topic szy

9、查看所有topic

# ./kafka-topics.sh --list --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181 

10、查看某个topic具体信息

# ./kafka-topics.sh --describe --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181 --topic szy

11、删除topic (可直接删除的前提:delete.topic.enable=true)

# ./kafka-topics.sh --delete --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181 --topic test 
命令无法删除,topic被标记为删除时候,用下面命令删除
# cd /usr/local/zookeeper-node3/bin/
# ./zkCli.sh
ls /brokers/topics
rmr /brokers/topics/【topic name】
quit

12、生产消息

# ./kafka-console-producer.sh --broker-list 172.16.218.201:19092,172.16.218.202:19092,172.16.218.203:19092 --topic szy 

13、消费消息

# ./kafka-console-consumer.sh --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181  --topic szy --from-beginning
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

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

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

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1、启动zookeeper
  • 2、查看zookeeper是否启动
  • 3、关闭zookeeper
  • 4、查看zookeeper的状态
  • 5、启动kafka
  • 6、查看kafka是否启动
  • 7、关闭kafka
  • 8、创建topic
  • 9、查看所有topic
  • 10、查看某个topic具体信息
  • 11、删除topic (可直接删除的前提:delete.topic.enable=true)
  • 12、生产消息
  • 13、消费消息
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档