目录
- 安装
- 启动
- 文件配置
- 测试启动
安装
前提条件，Java环境，zookeeper已经安装
brew install kafka 
如图所示则安装成功
启动
brew提供了一键启动的方式
zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties & kafka-server-start /usr/local/etc/kafka/server.properties
文件配置
测试启动
- 创建topic
kafka-topics –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test - 查看创建的topic
kafka-topics –list –zookeeper localhost:2181 发送一些消息
kafka-console-producer –broker-list localhost:9092 –topic test
消费消息
kafka-console-consumer –bootstrap-server localhost:9092 –topic test –from-beginning