1、安装java
注意:kafka 截止发稿日兼容最高版本为1.8 千万不要安装 更高版本 ,我就是安装了12的发现不支持卸载了重装的😂
这里提供一下下载地址吧,官网现在1.8的无法下载, https://download.csdn.net/download/chinayyj2010/11633015
安装过程忽略,
2、验证Java安装
希望你已经在你的机器上安装了java,所以你只需使用下面的命令验证它。
java -version
java version "1.8.0_221" Java(TM) SE Runtime Environment (build 1.8.0_221-b11) Java HotSpot(TM) 64-Bit Server VM (build 25.221-b11, mixed mode)
3、使用brew 安装kafka
打开终端输入命令:
brew install kafka
如上图,过程中会一直停了留在在 Updating Homebrew ... 此时可以执行ctrl + c 终止更新,继续安装。如图结果。
至此已经完成了安装,
安装位置以及配置文件路径都在图片上显示了,并且怎么启动也都告诉了我们
安装位置
/usr/local/Cellar/zookeeper
/usr/local/Cellar/kafka
配置文件位置
/usr/local/etc/kafka/server.properties
/usr/local/etc/kafka/zookeeper.properties
输入启动命令
kafka-server-start /usr/local/etc/kafka/server.properties
现在没有出现报错基本已经成功百分之90了,下面就是进行测试了
打开一个终端
#创建topic kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test #查看创建的topic kafka-topics --list --zookeeper localhost:2181 #终端1发送消息 kafka-console-producer --broker-list localhost:9092 --topic test
新开一个终端
#终端2接受消息
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
此时,在终端1中输入信息,终端2会立即显示在屏幕上面,如有结果输出,即安装成功
如下图