1、Kafka版本

3.2.1

1.1启动zookeeper

/usr/local/Cellar/kafka/3.2.1/bin/zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &

1.2检测是否启动成功

ps aux | grep zookeeper

2、启动Kafka

/usr/local/Cellar/kafka/3.2.1/bin/kafka-server-start /usr/local/etc/kafka/server.properties &

2.1检测是否启动成功

ps aux | grep kakfka

3、启动kafka消费者

kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic web_log --from-beginning