Kafka 安装步骤
-
安装步骤
在安装Kafka之前,请确保您的系统在以下任何操作系统上运行-- 任何Linux操作系统 - 支持开发和部署。它是演示应用程序的首选。
- Windows OS - 仅支持开发。
- Mac OS - 仅支持开发。
ZooKeeper服务器是用Java创建的,并且在JVM上运行。您需要使用JDK 6或更高版本。现在,按照下面给出的步骤在您的计算机上安装ZooKeeper框架。 -
验证JDK是否安装
相信您已经在系统上安装了Java环境。只需使用以下命令进行验证。$ java -version
如果您的计算机上安装了Java,则可以看到已安装Java的版本。否则,请按照下面给出的简单步骤安装最新版本的Java。步骤1.1:下载JDK通过访问以下链接下载最新版本的JDK,并下载最新版本。JDK,最新版本(撰写本教程时)为JDK 14.0.1,文件为“jdk-14.0.1-linuxx64.tar.gz”。请在您的计算机上下载文件步骤1.2:解压缩文件通常,文件会下载到download文件夹中。验证它并使用以下命令提取tar设置。$ cd /go/to/download/path $ tar -zxf jdk-14.0.1-linuxx64.tar.gz
步骤1.3:移至usr目录要使Java对所有用户可用,请将提取的Java内容移至“/usr/local/java”文件夹。步骤1.4:设定PATH环境变量要设置PATH和JAVA_HOME变量,请将以下命令添加到〜/.bashrc文件。export JAVA_HOME = /usr/jdk/jdk-14.0.1 export PATH=$PATH:$JAVA_HOME/bin
现在,将所有更改应用到当前正在运行的系统中。$ source ~/.bashrc
步骤1.5:Java替代品使用以下命令更改Java替代方案。update-alternatives --install /usr/bin/java java /opt/jdk/jdk-14.0.1/bin/java 100
步骤1.6使用步骤1中说明的验证命令(java -version
)验证Java安装。 -
ZooKeeper框架安装
步骤2.1:下载ZooKeeper要在您的计算机上安装ZooKeeper框架,请访问以下链接并下载最新版本的ZooKeeper。http://zookeeper.apache.org/releases.html,到目前为止,ZooKeeper的最新版本是3.6.0(ZooKeeper-3.6.0.tar.gz)。步骤2.2:解压缩tar文件使用以下命令解压缩tar文件-$ cd opt/ $ tar -zxf zookeeper-3.6.0.tar.gz $ cd zookeeper-3.6.0 $ mkdir data
步骤2.3:创建配置文件$ vi conf/zoo.cfg tickTime = 2000 dataDir = /path/to/zookeeper/data clientPort = 2181 initLimit = 5 syncLimit = 2
成功保存配置文件后,再次返回到终端。现在,您可以启动Zookeeper服务器。步骤2.4:启动ZooKeeper服务器,执行以下命令-$ bin/zkServer.sh start
执行此命令后,您将获得如下响应:$ JMX enabled by default $ Using config: /Users/../zookeeper-3.6.0/bin/../conf/zoo.cfg $ Starting zookeeper ... STARTED
步骤2.5:启动CLI键入以下命令-$ bin/zkCli.sh
键入上面的命令后,您将连接到ZooKeeper服务器,并且应该得到以下响应。Connecting to localhost:2181 ................ ................ ................ Welcome to ZooKeeper! ................ ................ WATCHER:: WatchedEvent state:SyncConnected type: None path:null [zk: localhost:2181(CONNECTED) 0]
停止ZooKeeper服务器连接服务器并执行所有操作后,可以使用以下命令停止Zookeeper服务器。$ bin/zkServer.sh stop
-
Apache Kafka安装
让我们继续以下步骤在您的计算机上安装Kafka。步骤3.1:下载Kafka要在您的计算机上安装Kafka,请点击以下链接- https://www.apache.org/dyn/closer.cgi?path=/kafka/1.0.0/kafka_2.12-1.0.0.tgz,现在,最新版本,即 – kafka_2.12-1.0.0.tgz将下载到您的计算机上。。步骤3.2:解压缩tar文件使用以下命令解压缩tar文件-$ cd opt/ $ tar -zxf kafka_2.12-1.0.0.tgz $ cd kafka_2.12-1.0.0
现在,您已经在计算机上下载了最新版本的Kafka。步骤3.3:启动服务器您可以通过提供以下命令来启动服务器-$ bin/kafka-server-start.sh config/server.properties
服务器启动后,您将在屏幕上看到以下响应:$ bin/kafka-server-start.sh config/server.properties [2016-01-02 15:37:30,410] INFO KafkaConfig values: request.timeout.ms = 30000 log.roll.hours = 168 inter.broker.protocol.version = 1.0.0.X log.preallocate = false security.inter.broker.protocol = PLAINTEXT ……………………………………………. …………………………………………….
-
停止服务器
完成所有操作后,您可以使用以下命令停止服务器:$ bin/kafka-server-stop.sh config/server.properties
既然我们已经讨论了Kafka的安装,我们将在下一章学习如何在Kafka上执行基本操作。