1、安装homebrew前提下

执行命令：brew install kafka

2、修改kafka/server.properties

执行命令：vi /usr/local/etc/kafka/server.properties

增加：listeners=PLAINTEXT://localhost:9092

3、启动zoopkeeper

执行命令：zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &

4、启动kafka

执行命令：kafka-server-start /usr/local/etc/kafka/server.properties &

5、创建topic

执行命令（kafka/bin目录下，新建cmd窗口）：kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

执行命令查看已创建的topic： kafka-topics --list --zookeeper localhost:2181

6、创建生产者

执行命令（kafka/bin目录下，新建cmd窗口）：./kafka-console-producer --topic test --broker-list localhost:9092（在下面输入信息）

7、创建消费者

执行命令（kafka/bin目录下，新建cmd窗口）：./kafka-console-consumer --bootstrap-server localhost:9092 -topic test（可看到输入的信息）