Mac安装与启动kafka
安装的方法:利用终端直接安装brew install kafka通过brew安装,会默认直接安装最新的版本。因为我的电脑系统版本比较低,所以brew不支持最新的kafka版本。本文介绍的是通过官网下载安装包的方式。通过官网下载安装包安装有两个步骤:下载zookeeper(或者也可以使用kafka内置的zookeeper),因为kafka依赖zookeeper,所以在启动kafka前必须先启动zoo
·
安装的方法:
利用终端直接安装
brew install kafka
通过brew安装,会默认直接安装最新的版本。
因为我的电脑系统版本比较低,所以brew不支持最新的kafka版本。本文介绍的是通过官网下载安装包的方式。
通过官网下载安装包安装
有两个步骤:
- 下载zookeeper(或者也可以使用kafka内置的zookeeper),因为kafka依赖zookeeper,所以在启动kafka前必须先启动zookeeper。
- 下载Kafka
下载Zookeeper
下载地址:http://archive.apache.org/dist/zookeeper/
选择自己电脑合适的版本。
之后进到zookeeper的相对应的目录
解压(以下是本机的对应目录)
cd Downloads
tar -xzf zookeeper-3.4.6.tar.gz
解压之后往conf文件夹下加一个zoo.cfg
注意:里面的dataDir和DataLogDir要修改一下,换成你自己电脑上的zookeeper地址
# 服务器与客户端之间交互的基本时间单元(ms)
tickTime=2000
# zookeeper所能接受的客户端数量
initLimit=10
# 服务器和客户端之间请求和应答之间的时间间隔
syncLimit=5
# zookeeper中使用的基本时间单位, 毫秒值.
tickTime=2000
# 数据目录. 可以是任意目录.
dataDir=你的zookeeper路径+/dataDir
# log目录, 同样可以是任意目录. 如果没有设置该参数, 将使用和#dataDir相同的设置.
dataLogDir=你的zookeeper路径+/dataLogDir
# t监听client连接的端口号.
clientPort=2181
下载kafka
下载地址:https://kafka.apache.org/downloads.html
注意:一定不要下成源文件了,是不带有-src 的文件
解压(以下是本机的对应目录)
cd Downloads
tar -xzf kafka_2.11-2.3.1.tar
启动zookeeper
##进入到自己相对应的目录
cd Downloads/zookeeper-3.4.6
bin/zkServer.sh start
看到下面这样就启动成功了!
启动kafka
另起窗口
进入到自己相对应的目录
##进入到自己相对应的目录
cd Downloads/kafka_2.11-2.3.1
##启动kafka
bin/kafka-server-start.sh config/server.properties
创建topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
可以通过下面命令查看topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
创建生产者
另起窗口
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my_test
创建消费者
另起窗口
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_test --from-beginning
到这里就所有就准备就绪了!!!
此时,你在生产者中写一个信息,消费者中就会出现一个信息。
单点的kafka环境部署完毕!!!
更多推荐
已为社区贡献1条内容
所有评论(0)