MAC安装Kafka

1、安装kafka

brew install kafka

直接安装kafka即可,因为kafka依赖zookeeper,安装kafka时zookeeper会自动安装。

截个图:

MAC安装Kafka

 

2、启动zookeeper

nohup zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &

MAC安装Kafka

然后查看一下是否启动:

MAC安装Kafka

启动正常! 

如果不启动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)

截个图:

MAC安装Kafka

 

3、启动kafka

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

MAC安装Kafka

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

MAC安装Kafka

 

6、开启一个终端,发送消息

kafka-console-producer --broker-list localhost:9092 --topic test

 

7、开启一个终端,接受消息

kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning

MAC安装Kafka

 

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