Windows下安装与使用Kafka(使用Kafka内置的ZooKeeper图文结合版)

文章目录

• • Windows安装Kafka
  • • 1.安装JDK并配置好对应的环境变量
    • 2.安装配置Zookeeper
    • • 1.下载安装包Apache Zookeeper
      • 2.解压并进入Zookeeper目录
      • 防止端口8080启动后被占用，这里考虑先配置下
      • • 3.安装Kafka
        • • 3.1 下载安装包
          • 3.2、 解压并进入Kafka目录，

            Windows安装Kafka

            1.安装JDK并配置好对应的环境变量

            

            ● 新建一个文件夹jre

            

            ● 1.环境变量如下-安装的路径

            

            ● 2.点击path新建

            

            ● 3.建一个系统变量

            

            .;%JAVA_HOME%\lib;%JAVA_HOME%\lib\dt.jar;%JAVA_HOME%\lib\tools.jar
            

            2.安装配置Zookeeper

            1.下载安装包Apache Zookeeper

            下载

            2.解压并进入Zookeeper目录

            ● 2.1将conf下的zoo_sample.cfg重命名为 zoo.cfg

            

            ● 2.2 打开zoo.cfg，修改数据存放位置dataDir

            dataDir=D:/OnlineSoftWare/apache-zookeeper-3.7.1/data

            dataDir=D:/OnlineSoftWare/apache-zookeeper-3.7.1/data
            # 防止端口8080启动后被占用，这里考虑先配置下
            admin.serverPort=8081
            

            防止端口8080启动后被占用，这里考虑先配置下

            admin.serverPort=8081

            

            ● 2.3 添加系统变量

            

            ● 2.4在path新建一个

            

            3.打开新的cmd，输入"zkServer"，运行Zookeeper

            

            ● 只要不报错就是成功，如果报错下面这个只需要把2.2的admin端口配置了

            Caused by: java.io.IOException: Failed to bind to /0.0.0.0:8080
                at org.eclipse.jetty.server.ServerConnector.openAcceptChannel(ServerConnector.java:346)
                at org.eclipse.jetty.server.ServerConnector.open(ServerConnector.java:308)
                at org.eclipse.jetty.server.AbstractNetworkConnector.doStart(AbstractNetworkConnector.java:80)
                at org.eclipse.jetty.server.ServerConnector.doStart(ServerConnector.java:236)
                at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)
                at org.eclipse.jetty.server.Server.doStart(Server.java:396)
                at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)
                at org.apache.zookeeper.server.admin.JettyAdminServer.start(JettyAdminServer.java:103)
                ... 5 more
            Caused by: java.net.BindException: Address already in use: bind
                    at sun.nio.ch.Net.bind0(Native Method)
                    at sun.nio.ch.Net.bind(Net.java:433)
                    at sun.nio.ch.Net.bind(Net.java:425)
                    at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)
                    at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)
                    at org.eclipse.jetty.server.ServerConnector.openAcceptChannel(ServerConnector.java:342)
                    ... 12 more
            Unable to start AdminServer, exiting abnormally
            

            注意不能关闭这个接口~因为kafka需要先启动zookeeper!

            3.安装Kafka

            3.1 下载安装包

            Kafka下载

            下载二进制版本，如图

            

            3.2、 解压并进入Kafka目录，

            笔者：D:\OnlineSoftWare\kafka_2.13-3.3.1

            

            3、 进入config目录找到文件server.properties并打开

            找到并编辑日志保存的位置 log.dirs、listener,其中kafka-logs是自己新建的文件夹

            listeners=PLAINTEXT://0.0.0.0:9092
            advertised.listeners=PLAINTEXT://localhost:9092
            log.dirs=D:\OnlineSoftWare\kafka_2.13-3.3.1\kafka-logs
            broker.id=1
            

            

            进入Kafka安装目录D:\OnlineSoftWare\kafka_2.13-3.3.1，按下Shift+右键，选择“打开命令窗口”选项，打开命令行

            

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

            

            到这里就安装完毕了！

            linux下安装的还在编写中…