网站建立的具体步骤,福建公司网站建设,上海软件外包公司名单,上海网站商城建设公司本文讲述Windows(win10)下安装Kafka3的方法。基本流程跟《CentOS下安装Kafka3》一样#xff0c;也是一样需要先安装Java环境#xff0c;再部署部署Kafka。 首先在官网 Apache Kafka 下载Kafka二进制压缩包。无论是在CentOS还是在Windows下都是下载该压缩包#xff0c;里面已…本文讲述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 然后就可以看到生产者和消费者进行通讯了
