Windows上安装Kafka4.0

首先下载安装编译好的安装包，下载地址：https://kafka.apache.org/downloads。 这里之所以称他为4.0,是因为网站上那样写的。安装包的版本标注好像又不是。

安装

这里安装kafka其实就是解压就了。比如我随便解压到了一个目录上E:\apps\kafka_2.13-4.0.0。 然后在他的config目录下有个server.properties。 打开之后找到log.dirs配置项，为了测试方便，我将其改到该目录下E:/apps/kafka_2.13-4.0.0/data

log.dirs=E:/apps/kafka_2.13-4.0.0/data

JDK

jdk的安装就不赘述了，这里提一下的原因就是因为,这个高版本的kafka是基于JDK17来编译的。所以JAVA_HOME弄到17上吧。

启动

这里只是启动单机版

格式化日志目录

首先生成一个随机的cluster.id,在命令控制台cmd上进入到目录bin\windows。

kafka-storage.bat random-uuid

然后他就会输出一个uuid。我这里是0vJqs3JPTJiq1qfd0VG4yw

接下来就用这个uuid作为cluster.id来格式化日志（其实就是kafka的topic数据那些）目录。
执行命令

kafka-storage.bat format --standalone -t 0vJqs3JPTJiq1qfd0VG4yw -c ../../config/server.properties

初始化完之后在日志目录E:\apps\kafka_2.13-4.0.0\data中配置好meta.properties等信息.

启动服务

做完初始化就可以启动单机服务了,启动命令如下

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

测试

创建topic

kafka-topics.bat --create --topic quickstart-events --bootstrap-server localhost:9092

启动一个消费端

启动一个消费端来接收topic消息, 命令如下：

kafka-console-consumer.bat --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

启动一个生产端

命令如下

kafka-console-consumer.bat --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

测试

在生产端发送消息，消费端收到消息

生产端的操作

消费端的操作