前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >消息中间件--04. Kafka常用的命令

消息中间件--04. Kafka常用的命令

作者头像
付威
发布2020-02-20 11:36:15
3160
发布2020-02-20 11:36:15
举报
文章被收录于专栏:老付的网络博客

启动zookeeper

代码语言:javascript
复制
$ bin/zkServer.sh start conf/zoo.cfg &
$ bin/zkCli.sh   

启动Kafka

我们启动两个实例:

代码语言:javascript
复制
$ bin/kafka-server-start.sh -daemon config/server.properties
$ bin/kafka-server-start.sh -daemon config/server-1.properties  

启动后,使用jps进程查看对应的kafka进程:

Kafka常用的命令
Kafka常用的命令

创建主题

现在我们来创建一个名字为testTopictestTopic1 的Topic,这个topic有两个partition,并且备份因子也设置为2:

代码语言:javascript
复制
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 2 --topic testTopic
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 2 --topic testTopic1

查看Kafka的实例

代码语言:javascript
复制
$ bin/zkCli.sh 
$ ls /   #查看zk的根目录kafka相关节点
$ ls /brokers/ids #查看kafka节点
Kafka常用的命令
Kafka常用的命令

查看所有的topic

代码语言:javascript
复制
bin/kafka-topics.sh --list --zookeeper localhost:2181
Kafka常用的命令
Kafka常用的命令

除了我们通过手工的方式创建Topic,我们可以配置broker,当producer发布一个消息某个指定的Topic,但是这个Topic并不存在时,就自动创建。

查看partition的作用

代码语言:javascript
复制
 bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic testTopic
Kafka常用的命令
Kafka常用的命令

发送消息

代码语言:javascript
复制
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic

消费消息

代码语言:javascript
复制
 bin/kafka-console-consumer.sh --bootstrap-server localhost:9092  --consumer-property group.id=testGroup --consumer-property client.id=consumer-1  --topic testTopic  

删除Topic

代码语言:javascript
复制
  kafka-topics.sh --zookeeper localhost:2181 --delete --topic <topic_name>

(本文完)

作者:付威 博客地址:http://blog.laofu.online 本文是付威的网络博客原创,自由转载-非商用-非衍生-保持署名,请遵循:创意共享3.0许可证 交流请加群113249828: 点击加群   或发我邮件 laofu_online@163.com

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2020-02-13 ,如有侵权请联系 cloudcommunity@tencent.com 删除

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

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

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

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 启动zookeeper
  • 启动Kafka
  • 创建主题
  • 查看Kafka的实例
  • 查看所有的topic
  • 查看partition的作用
  • 发送消息
  • 消费消息
  • 删除Topic
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档