Windows下安装Kafka3

这篇具有很好参考价值的文章主要介绍了Windows下安装Kafka3。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

本文讲述Windows(win10)下安装Kafka3的方法。基本流程跟《CentOS下安装Kafka3》一样,也是一样需要先安装Java环境,再部署部署Kafka。

首先在官网 Apache Kafka 下载Kafka二进制压缩包。无论是在CentOS还是在Windows下都是下载该压缩包,里面已经包含了Kafka Linux和windows平台下的可执行文件了。选择目前比较新的3.6.1版本下载。

kafka3 window,windows编程,windows

一、安装Java环境

 Kafka 是用 Java 开发的,因此需要安装java环境。如果不安装java启动zookeeper会报错:“系统找不到指定路径”,具体参考:《kafka启动过程中遇到问题:系统找不到指定路径》。从Kafka的官方文档 Apache Kafka 可以看到,Kafka3.6.1需要的java环境为Java8 或以上(不同版本的Kafka需要的Java环境版本也不一样)。

kafka3 window,windows编程,windows

从Java官网Java Downloads | Oracle 下载 Windows下的JDK

kafka3 window,windows编程,windows

参考《windows系统安装jdk》安装jdk,设置Java环境变量。“此电脑” -> “属性” -> “高级系统设置”-> “环境变量” -> “系统变量”

配置“JAVA_HOME”变量,设置变量值为:“D:\SoftWare\jdk-1.8”(按照个人的jdk安装路径为准)

kafka3 window,windows编程,windows

配置“CLASSPATH”变量,设置变量值为:“.;%JAVA_HOME%\lib\dt.jar;%JAVA_HOME%\lib\tools.jar”

kafka3 window,windows编程,windows

配置“Path”变量,设置变量值为:“.;%JAVA_HOME%\bin;%JAVA_HOME%\jre\bin;C:\Windows\System32\wbem;C:\Windows\System32”

kafka3 window,windows编程,windows

上述Path变量比 文章 《windows系统安装jdk》中多设置了C:\Windows\System32\wbem。是为了防止Kafka运行时报错:“’wmic’ 不是内部或外部命令,也不是可运行的程序或批处理文件”。参考《cmd运行wmic提示‘wmic‘ 不是内部或外部命令,也不是可运行的程序或批处理文件》。

执行上述操作后,Windows cmd输入java -version,显示java版本号;输入javac显示其选项,说明jdk安装成功了。

kafka3 window,windows编程,windows

二、安装部署Kafka

将之前下载下来的Kafka压缩包kafka_2.12-3.6.1.tgz解压,可以看到目录结构如下:

kafka3 window,windows编程,windows

kafka3版本之后自带zookeeper。配置zookeeper的配置文件config/zookeeper.properties,设置快照存贮路径:

kafka3 window,windows编程,windows

配置Kafka的配置文件config/server.properties:

kafka3 window,windows编程,windows

启动zookeeper:

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

启动kafka:

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

通过netstat命令查看到9092端口被一个java进程占用,说明启动成功了

kafka3 window,windows编程,windows

kafka3 window,windows编程,windows

三、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

然后就可以看到生产者和消费者进行通讯了:

kafka3 window,windows编程,windows

kafka3 window,windows编程,windows文章来源地址https://www.toymoban.com/news/detail-859289.html

到了这里,关于Windows下安装Kafka3的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • kafka3.x详解

    1、目前企业中比较常见的消息队列产品主 要有 Kafka、ActiveMQ 、RabbitMQ 、RocketMQ 等。 在 大数据场景 主要采用 Kafka 作为消息队列。在 JavaEE 开发中主要采用 ActiveMQ、RabbitMQ、RocketMQ。 2、Kafka与其他消息队列MQ(如ActiveMQ、RabbitMQ等)相比,有以下几个区别: 磁盘存储: Kafka将所

    2024年02月05日
    浏览(19)
  • kafka3.6.0集群部署

    环境准备 机器环境 系统 主机名 IP地址 centos7.9 kafka01 192.168.200.51 centos7.9 kafka02 192.168.200.52 centos7.9 kafka03 192.168.200.53 所需软件 hosts设置 java环境设置 zookeeper安装部署 创建软件安装目录 解压安装 修改配置 分发软件 kafka02与kafka03软链接 kafka02与kafka03修改myid 防火墙放行端口 设置

    2024年02月04日
    浏览(27)
  • 尚硅谷kafka3.0.0

    目录 💃概述 ⛹定义 ​编辑⛹消息队列 🤸‍♂️消息队列应用场景 ​编辑🤸‍♂️两种模式:点对点、发布订阅 ​编辑⛹基本概念 💃Kafka安装 ⛹ zookeeper安装 ⛹集群规划 ​编辑⛹流程 ⛹原神启动 🤸‍♂️批量脚本 ⛹topics常规操作 ⛹生产者命令行操作  ⛹消费者命令

    2024年02月06日
    浏览(23)
  • 【Kafka】Kafka3.3.1集群搭建指南KRaft版本

    目录 一、背景和描述 二、资源情况 三、技术选型 四、部署Kraft版本集群 五、配置SSL模式 六、Springboot使用SSL集成 参考资料 考虑资源安全性,需要搭建不依赖Zookeeper的kafka集群环境,并且配置SSL访问控制 Apache Kafka Raft 是一种共识协议,它的引入是为了消除 Kafka 对 ZooKeeper 的

    2024年02月05日
    浏览(42)
  • 【Kafka】Kafka3.1.1集群搭建指南KRaft版本

    目录 一、背景和描述 二、资源情况 三、技术选型 四、部署Kraft版本集群 五、配置SSL模式 六、Springboot使用SSL集成 参考资料 考虑资源安全性,需要搭建不依赖Zookeeper的kafka集群环境,并且配置SSL访问控制 Apache Kafka Raft 是一种共识协议,它的引入是为了消除 Kafka 对 ZooKeeper 的

    2024年02月03日
    浏览(28)
  • Kafka3.0.0版本——文件清理策略

    1.1、文件清理策略的概述 Kafka 中默认的日志保存时间为 7 天,可以通过调整如下参数修改保存时间。 参数 解释 log.retention.hours 小时,最低优先级(默认 7天) log.retention.minutes 分钟 log.retention.ms 毫秒,最高优先级 log.retention.check.interval.ms 负责设置检查周期(默认 5 分钟) 1

    2024年02月09日
    浏览(34)
  • Kafka3.0.0版本——文件存储机制

    1.1、Topic 数据的存储机制的概述 Topic是逻辑上的概念,而partition是物理上的概念。 每个partition对应于一个log文件 ,该log文件中存储的就是Producer生产的数据。 Producer生产的数据会被不断追加到该log文件末端 ,为防止log文件过大导致数据定位效率低下, Kafka采取了 分片和 索引

    2024年02月09日
    浏览(29)
  • Kafka3.0.0版本——增加副本因子

    四台服务器 原始服务器名称 原始服务器ip 节点 centos7虚拟机1 192.168.136.27 broker0 centos7虚拟机2 192.168.136.28 broker1 centos7虚拟机3 192.168.136.29 broker2 centos7虚拟机4 192.168.136.30 broker3 2.1、先启动zookeeper集群 启动zookeeper集群 2.2、再启动kafka集群 启动kafka集群 3.1、增加副本因子的概述 在

    2024年02月09日
    浏览(25)
  • kafka3.X基本概念和使用

    本文\\\"kafka的概念\\\"部分是在[初谈Kafka][ https://juejin.im/post/5a8e7f296fb9a0635a6573e9]的基础上重新整理而成,看官自行选择阅读… kafka的概念 kafka是一个分布式的、可区分的、可复制的、基于发布、订阅的**“消息系统”**。 主要应用领域:大数据,当然,在分布式的系统中也有应用。

    2024年02月08日
    浏览(27)
  • linux部署kafka3.5.1(单机)

    kafka3.x版本需要jdk11以上版本才能更好的兼容,jdk11、jdk17都是LTS长期维护版本,而且jdk17支持springboot3.x,所以我选择了openjdk17。 下载地址:  Archived OpenJDK GA Releases https://jdk.java.net/archive/ openjdk-17_linux-x64_bin.tar.gz 安装包上传到服务器的安装目录 执行命令解压: tar -zxvf openjdk-17_

    2024年02月12日
    浏览(31)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包