Apache Kafka是一种消息流服务,允许分布式系统中的不同应用程序通过消息进行通信和共享数据。
它作为一个发布/子系统,生产者应用程序发布消息,消费者系统订阅消息。
Apache Kafka使您能够在生成和使用数据的系统部分之间采用松散耦合的体系结构。这使得系统的设计和管理更加简单。Kafka依赖Zookeeper进行元数据管理和集群不同元素的同步。
![图片[1]-如何下载和安装Apache Kafka[Windows和Linux]-北忘山博客](https://cdn.beiwangshan.com/uploads/2022/12/f192fff8ef235601.png)
在Windows上安装Kafka
首先,检查您的机器上是否安装了Java,以便在Windows上安装Apache Kafka。在管理员模式下打开命令提示符并输入命令:
java --version
如果安装了Java,您应该获得当前安装的JDK版本号。
如果您收到一条错误消息,说命令未被识别,则说明Java未安装,您需要安装Java。要安装Java,请访问Adoptium.net并单击下载按钮。
![图片[2]-如何下载和安装Apache Kafka[Windows和Linux]-北忘山博客](https://cdn.beiwangshan.com/uploads/2022/12/24af142d75235717.png)
这应该下载Java安装程序文件。下载完成后,运行安装程序。这将打开安装提示符。
反复按Next可选择默认选项。然后应开始安装。通过关闭命令提示符,在管理员模式下重新打开另一个命令提示器,然后输入以下命令来验证安装:
java --version
这一次,您应该得到刚刚安装的JDK版本。安装完成后,我们可以开始安装Kafka。
要安装Kafka,请首先转到Kafka website
点击链接,你就会进入下载页面。下载可用的最新二进制文件。
![图片[3]-如何下载和安装Apache Kafka[Windows和Linux]-北忘山博客](https://cdn.beiwangshan.com/uploads/2022/12/43fb937913235837.png)
这将下载打包在.tgz
文件。下载后,必须从.tgz存档中提取文件。
解压缩文件后,将其移动到C:\
这样文件路径就变成C: \kafka(卡夫卡)
然后在管理员模式下打开命令提示符,首先导航到Kafka目录,启动Zookeeper。并以zookeeper.properties作为配置文件运行zookeper-server-start.bat文件
cd C:\kafka
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
随着Zookeeper的运行,我们需要添加wmic
Kafka在我们的系统PATH中使用的可执行文件,
set PATH=C:\Windows\System32\wbem\;%PATH%;
在此之后,通过在管理员模式下打开另一个命令提示符会话并导航到C:\kafka
文件夹
cd C:\kafka
然后通过跑步启动kafka卡夫卡
bin\windows\kafka-server-start.bat config\server.properties
有了这个,卡夫卡应该开始跑步了。您可以自定义服务器属性,例如日志写入的位置server.properties
文件
在Linux上安装Kafka
sudo apt update && sudo apt upgrade
接下来,通过运行
java --version
如果java
安装后,您将看到版本号。但是,如果不是,可以使用安装恰当的
.
sudo apt install default-jdk
在此之后,我们可以通过从以下位置下载二进制文件来安装Apache Kafka网站 .
打开终端并导航到保存下载的文件夹。在我的情况下,我必须导航到Downloads文件夹。
cd Downloads
进入下载文件夹后,使用tar
:
tar -xvzf kafka_2.13-3.3.1.tgz
导航到提取的文件夹
cd kafka_2.13-3.3.1.tgz
列出目录和文件
进入文件夹后,通过运行zookeeper-server-start.sh
脚本位于箱子
解压缩文件夹的目录
该脚本需要一个Zookeeper配置文件。默认文件名为zookeeper.properties
位于配置
子目录
因此,要启动服务器,请使用以下命令:
bin/zookeeper-server-start.sh config/zookeeper.properties
运行Zookeeper后,我们可以启动Apache Kafka服务器。这个kafka-server-start.sh
脚本也位于箱子
目录。该命令还需要一个配置文件。默认值为server.properties
存储在配置
文件
bin/kafka-server-start.sh config/server.properties
这应该可以让Apache Kafka运行起来。在内部bin
目录中,您将找到许多脚本来执行诸如创建主题、管理生产者和管理消费者等操作。您还可以在中自定义服务器属性服务器属性
文件
暂无评论内容