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上执行基本操作。