Mac下安装Kafka

kafka

安装

brew install kafka

brew cask install java

zookeeper

修改

server.properties

vim /usr/local/etc/kafka/server.properties
增加一行配置
listeners=PLAINTEXT://localhost:9092

首先我们启动

zookeeper

zkserver start

启动

kafka server

cd /usr/local/Cellar/kafka/0.10.1.0/bin

./kafka-server-start /usr/local/etc/kafka/server.properties

新建

session

查看

kafka

的

topic

./kafka-topics --list --zookeeper localhost:2181

一般产出的是test

启动

kafka

的生产者

./kafka-console-producer --topic [topic-name] --broker-list localhost:9092

开启一个

kafka

消费者

./kafka-console-consumer --bootstrap-server localhost:9092 -topic [topic-name]