kafka的安装路径:/usr/local/Cellar/kafka/3.2.0
kafka的配置路径:/usr/local/etc/kafka开启zookeeper
cd /usr/local/Cellar/kafka/3.2.0
执行脚本启动zookeeper:
bin/zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties启动kafka,在打开一个窗口:
cd /usr/local/Cellar/kafka/3.2.0
执行脚本启动kafka:
bin/kafka-server-start /usr/local/etc/kafka/server.properties测试创建一个主题,再打开一个窗口
cd /usr/local/Cellar/kafka/3.2.0
执行命令,创建一个主题
网上介绍的写法:bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic wangyake-test 这个对于3.0.0的kafka已经不适用了
正确的是:bin/kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic wangyake-test
其中--bootstrap-server localhost:9092 指出了要连接的kafka的服务器的地址,必填项,zookeeper的地址在kafka的配置中有,启动的时候就会默认链接。
–create 创建主题命令