1 使用brew工具来安装,只需要一条命令就完成了下载和安装的过程
brew install kafka
安装完成后可以看到Kafka安装的路径和配置文件路径
/usr/local/Cellar/kafka/3.1.0
/usr/local/etc/kafka/
2 启动Kafka依赖zookeeper,而Kafka中默认有一个单机版的zookeeper。实际生产部署中不推荐使用默认的zookeeper
2.1 启动zookeeper
在kafka的安装目录下,执行脚本启动zookeeper
cd /usr/local/Cellar/kafka/3.1.0
bin/zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties
2.2 启动Kafka
新开一个控制窗口,在Kafka安装目录下,执行脚本启动kafka
cd /usr/local/Cellar/kafka/3.1.0
bin/kafka-server-start /usr/local/etc/kafka/server.properties
3 测试
3.1 首先创建一个主题(topic)
在Kafka安装目录下,创建一个主题
cd /usr/local/Cellar/kafka/3.1.0
bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
bin/kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test(2.2 及更高版本)
查看是否成功创建主题
bin/kafka-topics --list --zookeeper localhost:2181
bin/kafka-topics --list --bootstrap-server localhost:9092(2.2 及更高版本)
3.2 生产消费测试
新开一个窗口,创建一个生产者:
bin/kafka-console-producer --broker-list localhost:9092 --topic test
新开一个窗口,创建一个消费者:
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
然后用生产者发送消息,消费者就可以消费到数据了。
问题记录:
解决 Exception in thread “main“ joptsimple.UnrecognizedOptionException: zookeeper is not a recognized问题
解决方案:
在较新版本(2.2 及更高版本)的 Kafka 不再需要 ZooKeeper 连接字符串,
即- -zookeeper localhost:2181。使用 Kafka Broker的 --bootstrap-server localhost:9092来替代- -zookeeper localhost:2181。