Mac 下kafka安装、启动与测试

第一步 安装

brew install kafka

默认会把zookeeper一起装好
安装路径

/usr/local/Cellar/zookeeper/3.4.14
/usr/local/Cellar/kafka/2.3.0

配置文件路径

/usr/local/etc/kafka/server.properties
/usr/local/etc/kafka/zookeeper.properties

第二步 启动

kafka是基于zookeeper的，启动kafka之前，需要先启动zookeeper

启动zookeeper

进入到安装路径 cd /usr/local/etc/kafka

zookeeper-server-start zookeeper.properties &  启动

ps aux | grep zookeeper 查看是否启动成功

启动kafka

kafka-server-start server.properties & 启动

ps aux | grep kafka 查看是否启动成功

第三步 测试

进入kafka安装目录

cd /usr/local/Cellar/kafka/2.3.0

创建一个topic

bin/kafka-topics --create --zookeeper localhost:9092--replication-factor 1 --partitions 1 --topic my_first_topic

create 创建主题命令
zookeeper localhost:9092 指定zookeeper
replication-factor 1 指定副本个数
partitions 1 指定分区个数
topic my_first_topic 主题名称为my_first_topic

查看topic列表

kafka-topics --list --zookeeper localhost:9092
# 输出：
__consumer_offsets
my_first_topic

创建一个生产者

# 新启动一个窗口输入命令创建一个生产者
kafka-console-producer --broker-list localhost:9092 --topic my_first_topic

创建一个消费者

# 打开启动一个（多个）窗口输入命令创建一个（多个）消费者
kafka-console-consumer --bootstrap-server localhost:9092 --topic sunday --from-beginning

效果

生产者

image.png

消费者

image.png

最后 关闭

# 停止kafka
/usr/local/Cellar/kafka/2.3.0/bin/kafka-server-stop
# 停止zookeeper
/usr/local/Cellar/kafka/2.3.0/bin/zookeeper-server-stop