栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

在mac上安装kafka

在mac上安装kafka

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)

 

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/278380.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号