安装 kafka集群(端口:9092)

  1. 安装 zookeeper集群:
    参见:源码安装 zookeeper集群3.4.11

  2. 下载压缩包:
    wget https://archive.apache.org/dist/kafka/2.2.0/kafka_2.12-2.2.0.tgz

  3. 解压:

    tar -xzf kafka_2.12-2.2.0.tgz
    mv kafka_2.12-2.2.0 /usr/local/kafka
  4. 创建日志目录:
    mkdir /usr/local/kafka/logs

  5. 修改配置文件,分别给每台机器分配 broker.id(1、2、3):
    vim /usr/local/kafka/config/server.properties

    broker.id=1
    log.dirs=/usr/local/kafka/logs
    zookeeper.connect=10.0.0.11:2181,10.0.0.12:2181,10.0.0.13:2181
    delete.topic.enable=true
  6. 分别启动服务:
    /usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties

  7. 添加命令到环境变量:
    vim /etc/profile

    export KAFKA_HOME=/usr/local/kafka
    export PATH=$PATH:$KAFKA_HOME/bin

    . /etc/profile

安装 kafka-manager

  1. 下载压缩包:
    wget http://file.job520.net/linux/other/kafka-manager-2.0.0.2.zip

  2. 解压:

    unzip kafka-manager-2.0.0.2.zip
    mv kafka-manager-2.0.0.2 /usr/local/kafka-manager
  3. 修改配置文件:
    vim /usr/local/kafka-manager/conf/application.conf

    # 修改为 zookeeper集群地址
    kafka-manager.zkhosts="10.0.0.11:2181,10.0.0.12:2181,10.0.0.13:2181"
  4. 启动:
    /usr/local/kafka-manager/bin/kafka-manager -Dconfig.file=/usr/local/kafka-manager/conf/application.conf -Dhttp.port=8080

  5. 访问地址:
    10.0.0.11:8080

文档更新时间: 2024-04-20 10:57   作者:lee