ARM_KAFKA搭建

一、搭建环境

搭建服务器IP环境kafka版本号
20.10.0.xxCentOS Linux release 7.9.2009 (AltArch)kafka_2.12-2.20
20.10.0.xxCentOS Linux release 7.9.2009 (AltArch)zookeeper_3.7.0

二、搭建步骤

1、使用docker-compose容器管理文件进行一键启动docker环境。

安装路径为:/data/kafka

version: '3.2'
    services:
      zookeeper:
        image: zookeeper
        ports:
          - "2181:2181"
        privileged: true
        volumes:
          - /data/zook/data:/data
          - /data/zook/datalog:/datalog 
          - /etc/localtime:/etc/localtime
        container_name: "zookeeper"
        restart: always
      kafka:
        image: wyh1791/kafka-arm64v8
        container_name: "kafka"
        ports:
          - "9092:9092"
        privileged: true
        environment:
          - TZ=Asia/Shanghai
          - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
          - KAFKA_AUTO_CREATE_TOPICS_ENABLE=true
          - KAFKA_ADVERTISED_HOST_NAME=20.10.0.xx
          - KAFKA_ADVERTISED_PORT=9092
          - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://20.10.0.xx:9092
          - KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092
          - KAFKA_HEAP_OPTS=-Xmx16G -Xms16G
          - KAFKA_LOG_RETENTION_HOURS=168
        volumes:
          - /data/kafka/kafka_data:/kafka
          - /var/run/docker.sock:/var/run/docker.sock
          - /etc/localtime:/etc/localtime
        restart: always
2、kafka启动
docker-compose up -d       #默认文件下可以这样启动,如果不是默认文件名 -f指定文件名进行启动

三、测试

搭建部署好后,进行docker容器测试:

1、创建topic

/opt/kafka/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

2、topic列表查询

/opt/kafka/bin/kafka-topics.sh --zookeeper 20.10.0.xx:2181 --list

3、启动kafka生产者

/opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

4、启动kafka消费者

/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

总结:上述如果执行无问题,生产者、消费者互通并可消费到说明kafka搭建成功。进行程序连接测试。

Logo

更多推荐