此篇介绍一下如何在Mac系统上进行安装和使用Kafka环境。

环境安装

在Mac系统上安装最方便的还是使用brew工具命令：

brew cask install java
brew install zookeeper
brew install kafka

安装后的目录

二进制文件和脚本文件在 /usr/local/bin 目录下
Kafka 配置文件在 /usr/local/etc/kafka 目录下
Zookeeper 配置文件在 /usr/local/etc/zookeeper 目录下
log.dirs(Kafka 的数据目录)被设置为 /usr/local/var/lib/kafka-logs

配置修改

修改 /usr/local/etc/kafka/server.properties 文件，将

#listeners=PLAINTEXT://:9092

修改为

listeners=PLAINTEXT://localhost:9092

功能验证

启动服务

brew services start zookeeper
brew services start kafka

创建Topic

kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testkafka

2181是zookeeper使用的端口

查看Topic列表

kafka-topics --list --zookeeper localhost:2181

生产消息

$ kafka-console-producer --broker-list localhost:9092 --topic testkafka
>hello, kafka!

消费消息

  1. 直接消费

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

  1. 组(group)消费

kafka-console-consumer --bootstrap-server localhost:9092 --topic testkafka --group test-consumer1 --from-beginning

关闭服务

brew services stop kafka
brew services stop zookeeper