MAC安装Kafka
1、安装kafka
brew install kafka
直接安装kafka即可,因为kafka依赖zookeeper,安装kafka时zookeeper会自动安装。
截个图:
2、启动zookeeper
nohup zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &
然后查看一下是否启动:
启动正常!
如果不启动zookeeper,直接启动kafka,会出现拒绝连接的情况:
[2020-07-15 09:25:45,972] INFO Socket error occurred: localhost/0:0:0:0:0:0:0:1:2181: Connection refused (org.apache.zookeeper.ClientCnxn)
截个图:
3、启动kafka
nohup kafka-server-start /usr/local/etc/kafka/server.properties &
JPS命令查看有kafka进程出现即为成功!
4、创建Topic
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
5、查看Topic
kafka-topics --list --zookeeper localhost:2181
6、开启一个终端,发送消息
kafka-console-producer --broker-list localhost:9092 --topic test
7、开启一个终端,接受消息
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
8、关闭kafka
/usr/local/Cellar/kafka/2.5.0/bin/kafka-server-stop
9、关闭zookeeper
/usr/local/Cellar/kafka/2.5.0/bin/zookeeper-server-stop