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(可看到输入的信息)