参考文章:Windows下安装Kafka3_kafka3 window-CSDN博客
安装配置Kafka
首先在官网 Apache Kafka 下载Kafka二进制压缩包。无论是在CentOS还是在Windows下都是下载该压缩包,里面已经包含了Kafka Linux和windows平台下的可执行文件了。选择目前比较新的3.6.1版本下载
将之前下载下来的Kafka压缩包kafka_2.12-3.6.1.tgz解压,可以看到目录结构如下:
kafka3版本之后自带zookeeper。配置zookeeper的配置文件config/zookeeper.properties,设置快照存贮路径:
配置Kafka的配置文件config/server.properties
启动zookeeper
进入kafka安装目录,启动
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
启动kafka
bin\windows\kafka-server-start.bat config\server.properties
通过netstat命令查看到9092端口被一个java进程占用,说明启动成功了
netstat -ano | findstr "9092"
Kafka的基本操作
创建主题:
bin\windows\kafka-topics.bat --create --topic quickstart-events --bootstrap-server localhost:9092
查看主题属性:
bin\windows\kafka-topics.bat --describe --topic quickstart-events --bootstrap-server localhost:9092
新建两个终端,分别执行命令,通过生产者发送消息:
bin\windows\kafka-console-producer.bat --topic quickstart-events --bootstrap-server localhost:9092
通过消费者消费消息:
bin\windows\kafka-console-consumer.bat --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
然后就可以看到生产者和消费者进行通讯了: