Apache Kafka是一个开源流处理平台和消息系统,基于Scala语言编写,由Apache软件基金会开发。它提供了一种高吞吐量的分布式发布订阅消息系统,能够处理网站中的所有动作流数据。以下是在Windows 10系统中安装并运行Kafka的步骤:
首先,从官网Apache Kafka页面下载最新的版本(例如,最新版本为3.1.0),本文档以2020年5月发布的版本2.7.1为例进行说明。
为了运行Kafka,需要同时安装Zookeeper作为协调服务。下载对应的Zookeeper版本(例如,3.5.9),并将其解压到与Kafka相同的目录下,如D:\java。
接着,将Zookeeper的示例配置文件zoo_sample.cfg复制并重命名为zoo.cfg。双击Zookeeper的启动脚本zkServer.cmd,即可启动Zookeeper服务,通常它绑定在2181端口。
之后,下载Kafka版本2.13-2.7.1.tgz,并解压到D:\java目录下的kafka_2.13-2.7.1文件夹。在此目录下,server.properties文件是核心配置文件,其中包含两个关键设置:
- broker.id:用于集群配置时确保每台服务器(broker)的id唯一。
- zookeeper.connect:默认为localhost:2181,若使用Zookeeper集群,需设置为多个Zookeeper实例的连接,例如zookeeper.connect=zookeeper_hostname1:2181,zookeeper_hostname2:2181。
启动Kafka,只需在D:\java\kafka_2.13-2.7.1\bin\windows目录下执行命令即可,显示使用的版本和端口信息。
执行主题操作命令创建、查看和管理主题。例如,创建主题时需要设置分区和副本因子,通常情况下,由于系统资源限制,设置为1。
最后,通过生产者向特定主题发送消息,消费者则从该主题读取消息,实现消息的发布和订阅。
至此,Windows 10系统中的Kafka安装、运行与消息发布流程完成。
本文如未解决您的问题请添加抖音号:51dongshi(抖音搜索懂视),直接咨询即可。