您当前的位置：学无止境 > kafka的安装和简单使用网站首页学无止境

kafka的安装和简单使用

发布时间：2021-03-18 09:51:17编辑：sanqing查看次数：879

因为kafka需要java环境，所以先要安装jdk，可以参考：https://www.jianshu.com/p/efef80171a4a

kafka下载地址：http://kafka.apache.org/downloads

三青下载的是

https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.7.0/kafka_2.13-2.7.0.tgz  

三青用的是windows环境

windows下把/替换成反斜杠，mac和linux不需要加上windows目录，运行bin目录下对应文件即可。如有报错，可以重新启动zookeeper，kafka后再尝试

解压

启动zookeeper。cmd进去解压后的文件（config/zookeeper.properties是zookeeper配置文件）

bin/windows/zookeeper-server-start.bat config/zookeeper.properties

启动kafka。新窗口cmd进去解压后的文件（config/server.properties是kafka配置文件）

bin/windows/kafka-server-start.bat config/server.properties

创建主题（topic）。新窗口cmd进去解压后的文件（不同的版本可能不一样，可以参考文章下部链接）

bin/windows/kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic sanqing

查看主题

bin/windows/kafka-topics.bat --list --zookeeper localhost:2181

发送消息（每一行是一条消息）


bin/windows/kafka-console-producer.bat --broker-list localhost:9092 --topic sanqing

消费消息（可以多打开几个窗口）


bin/windows/kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic sanqing --from-beginning

参考：https://www.orchome.com/6