Mac

2024年06月16日

柏拉文

越努力，越幸运

一、认识

---

Kafka 可以通过 Homebrew 直接安装。安装完成后，默认情况下 Kafka 依赖 Zookeeper，需要先启动 Zookeeper，再启动 Kafka。

二、安装

---

brew update
brew install kafka

三、添加变量

---

在 Mac 上使用 brew install kafka 安装 Kafka 后，默认情况下，Kafka 的命令行工具（如 kafka-topics, kafka-console-producer 等）不会自动添加到环境变量 PATH 中。

// 1. 查看 kafka 安装路径 
brew info kafka

// 2. 将 Kafka 的 bin 目录加入 PATH 环境变量
echo 'export PATH="/opt/homebrew/Cellar/kafka/3.9.0/bin/$PATH"' >> ~/.zshrc
source ~/.zshrc

// 3. 测试 Kafka 命令是否成功
kafka-topics --version

四、启动服务

---

kafka-server-start /opt/homebrew/etc/kafka/server.properties

五、测试服务

---

// 1. 创建主题 test-topic 主题
kafka-topics --create --topic test-topic --bootstrap-server localhost:29092 --partitions 3 --replication-factor 1

// 2. 生产者发送消息，并输入 Hello Kafka ,按 control + c 退出
kafka-console-producer --topic test-topic --bootstrap-server localhost:29092 

// 3. 消费者消费消息
kafka-console-consumer --topic test-topic --from-beginning --bootstrap-server localhost:29092

六、停止服务

---