说在前面的话,首先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

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐