【kafka】常见命令集
说在前面的话,首先kafka命令集使用比较多的场景应该是基础架构的同学,一个合格的基础架构同学一定要对各种命令了如指掌;其次业务研发同学可能对这些命令用的就不多了,大多数使用kafka的场景都是通过代码编程,很少直接使用命令的,但是作为一个业务研发多多少少还是要知道其有哪些命令,并且是如何使用的。
·
说在前面的话,首先kafka命令集使用比较多的场景应该是基础架构的同学,一个合格的基础架构同学一定要对各种命令了如指掌;其次业务研发同学可能对这些命令用的就不多了,大多数使用kafka的场景都是通过代码编程,很少直接使用命令的,但是作为一个业务研发多多少少还是要知道其有哪些命令,并且是如何使用的。
环境:
- mac m2
- kafka版本:3.7.0
命令集:
1.mac终端安装kafka
#mac安装kafka
brew install kafka
2. mac安装kafka后一般存放路径(如果你忘记安装在哪了,可以到该路径下找找)
(以上一步命令安装后的路径为实际路径,记住就行,避免后续不知道安装在哪里了)
#安装路径
/opt/homebrew/Cellar/kafka/3.7.0
3. 安装后开启kafka和zookeeper服务
#开启服务
brew services restart kafka
#开启zookeeper
brew services start zookeeper
4.查看已创建的topic列表
#查看topic列表
kafka-topics --bootstrap-server localhost:9092 --list
5.创建一个topic
注:--replication-factor 1 :是分区副本数;--partitions 1 :分区数
下方命令的意思是:创建一个分区数量为1,分区副本数量为1,名为test1的topic
#创建kafka topic
kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test1
6.创建一个生产者
#创建一个生产者
kafka-console-producer --bootstrap-server localhost:9092 --topic test1
7.创建一个消费者
#创建一个消费者 不指定消费者组 从头开始消费
kafka-console-consumer --bootstrap-server localhost:9092 --topic test1 --from-beginning
#创建一个消费者 不知道消费者组 最新的开始消费
kafka-console-consumer --bootstrap-server localhost:9092 --topic test1
#指定消费者组
kafka-console-consumer --bootstrap-server localhost:9092 --topic test1 --group it.erge.test.topic.1 --from-beginning
8.查看消费者详情
#查看消费者详情
kafka-topics --bootstrap-server localhost:9092 --topic it.erge.test.topic.1 --describe
9.查看所有消费者group
#查看所有group
kafka-consumer-groups --bootstrap-server localhost:9092 --list
10.查看指定消费者gruop
#查看指定consumer group
kafka-consumer-groups --bootstrap-server localhost:9092 --group it.erge.test.topic.1 --describe
更多推荐
已为社区贡献2条内容
所有评论(0)