1. 我的环境

 

2. 安装步骤

2.1 在mac电脑上可以直接使用 brew install kafka来进行安装

如果安装出现Cannot install in Homebrew on ARM processor in Intel default prefix (/usr/local)!错误，那么使用下面解决方法：

打开Finder-> 打开应用程序->打开实用工具

找到终端.app，显示简介，把使用 Rosetta打开勾选上，然后重启终端，再运行brew install ，就可以了，最后装好了别忘了去掉勾

问题出现的愿意可以参看：

Cannot install in Homebrew on ARM processor in Intel default prefix - 简书

macos - Error: Cannot install in Homebrew on ARM processor in Intel default prefix (/usr/local) - Stack Overflow

出现以下结果就是安装成功了

从这个图我们看到，kafka的安装路径是/usr/local/Cellar/kafka/3.0.0

kafka的配置路径是/usr/local/etc/kafka

 

 2.2 开启zookeeper

cd /usr/local/Cellar/kafka/3.0.0

执行脚本启动zookeeper：

bin/zookeeper-server-start  /usr/local/etc/kafka/zookeeper.properties

 

启动kafka，在打开一个窗口

cd /usr/local/Cellar/kafka/3.0.0

执行脚本启动kafka：

bin/kafka-server-start /usr/local/etc/kafka/server.properties

如果想要后台启动，可以参看

 2.3 测试

测试创建一个主题，再打开一个窗口

cd /usr/local/Cellar/kafka/3.0.0

执行命令，创建一个主题

网上介绍的写法：bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic wangyake-test 这个对于3.0.0的kafka已经不适用了

正确的是：bin/kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic wangyake-test

其中--bootstrap-server localhost:9092 指出了要连接的kafka的服务器的地址，必填项，zookeeper的地址在kafka的配置中有，应该是启动的时候就会默认链接。

 kafka自己监听的端口

执行结果如下：

 服务器输出

 –create 创建主题命令
–replication-factor 1 指定副本个数
–partitions 1 指定分区个数
–topic test 主题名称

查看是否成功创建主题

bin/kafka-topics --list --bootstrap-server localhost:9092

 测试生产者（producer）与消费者（consumer）
打开一个窗口输入命令创建一个生产者：

bin/kafka-console-producer --broker-list localhost:9092 --topic wangyake-test

打开一个窗口输入命令创建一个消费者：

kafka-console-consumer --bootstrap-server localhost:9092 --topic wangyake-test --from-beginning

 其中 --from-beginning 参数的意思是：如果使用者尚未确定要使用的偏移量，请从日志中出现的最早消息开始，而不是从最新消息开始。(kafka-console-consumer  --help)