本文讲述Windows(win10)下安装Kafka3的方法。基本流程跟《CentOS下安装Kafka3》一样,也是一样需要先安装Java环境,再部署部署Kafka。
首先在官网 Apache Kafka 下载Kafka二进制压缩包。无论是在CentOS还是在Windows下都是下载该压缩包,里面已经包含了Kafka Linux和windows平台下的可执行文件了。选择目前比较新的3.6.1版本下载。
一、安装Java环境
Kafka 是用 Java 开发的,因此需要安装java环境。如果不安装java启动zookeeper会报错:“系统找不到指定路径”,具体参考:《kafka启动过程中遇到问题:系统找不到指定路径》。从Kafka的官方文档 Apache Kafka 可以看到,Kafka3.6.1需要的java环境为Java8 或以上(不同版本的Kafka需要的Java环境版本也不一样)。
从Java官网Java Downloads | Oracle 下载 Windows下的JDK
参考《windows系统安装jdk》安装jdk,设置Java环境变量。“此电脑” -> “属性” -> “高级系统设置”-> “环境变量” -> “系统变量”
配置“JAVA_HOME”变量,设置变量值为:“D:\SoftWare\jdk-1.8”(按照个人的jdk安装路径为准)
配置“CLASSPATH”变量,设置变量值为:“.;%JAVA_HOME%\lib\dt.jar;%JAVA_HOME%\lib\tools.jar”
配置“Path”变量,设置变量值为:“.;%JAVA_HOME%\bin;%JAVA_HOME%\jre\bin;C:\Windows\System32\wbem;C:\Windows\System32”
上述Path变量比 文章 《windows系统安装jdk》中多设置了C:\Windows\System32\wbem。是为了防止Kafka运行时报错:“’wmic’ 不是内部或外部命令,也不是可运行的程序或批处理文件”。参考《cmd运行wmic提示‘wmic‘ 不是内部或外部命令,也不是可运行的程序或批处理文件》。
执行上述操作后,Windows cmd输入java -version,显示java版本号;输入javac显示其选项,说明jdk安装成功了。
二、安装部署Kafka
将之前下载下来的Kafka压缩包kafka_2.12-3.6.1.tgz解压,可以看到目录结构如下:
kafka3版本之后自带zookeeper。配置zookeeper的配置文件config/zookeeper.properties,设置快照存贮路径:
配置Kafka的配置文件config/server.properties:
启动zookeeper:
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
启动kafka:
bin\windows\kafka-server-start.bat config\server.properties
通过netstat命令查看到9092端口被一个java进程占用,说明启动成功了
三、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
然后就可以看到生产者和消费者进行通讯了: