-
安装 kafka 执行命令：brew install kafka
-
修改 server.properties 执行命令：vi /usr/local/etc/kafka/server.properties 增加一行配置如下： listeners=PLAINTEXT://localhost:9092
-
启动 zookeeper 执行命令： zkServer start
-
以 server.properties 的配置，启动 kafka 执行命令：kafka-server-start /usr/local/etc/kafka/server.properties
-
新建 session，查看 kafka 的 topic 执行命令：kafka-topics –list –zookeeper localhost:2181
-
启动 kafka 生产者 执行命令：kafka-console-producer –topic [topic-name] –broker-list localhost:9092(第 2 步修改的 listeners)
-
启动 kafka 消费者 执行命令：kafka-console-consumer –bootstrap-server localhost:9092 —topic [topic-name]
