zoukankan      html  css  js  c++  java
  • docker-compose-kafka-cluster.yml

    version: '3.5'

    networks:
    docker_net:
    external: true

    services:

    kafka1:
    image: wurstmeister/kafka
    restart: unless-stopped
    container_name: kafka1
    ports:
    - "9093:9092"
    external_links:
    - zoo1
    - zoo2
    - zoo3
    environment:
    KAFKA_BROKER_ID: 1
    KAFKA_ADVERTISED_HOST_NAME: 192.168.142.142 ## 修改:宿主机IP
    KAFKA_ADVERTISED_PORT: 9093 ## 修改:宿主机映射port
    KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://192.168.142.142:9093 ## 绑定发布订阅的端口。修改:宿主机IP
    KAFKA_ZOOKEEPER_CONNECT: "zoo1:2181,zoo2:2181,zoo3:2181"
    volumes:
    - "/www/kafka/kafka1/docker.sock:/var/run/docker.sock"
    - "/www/kafka/kafka1/data/:/kafka"
    networks:
    - docker_net

    kafka2:
    image: wurstmeister/kafka
    restart: unless-stopped
    container_name: kafka2
    ports:
    - "9094:9092"
    external_links:
    - zoo1
    - zoo2
    - zoo3
    environment:
    KAFKA_BROKER_ID: 2
    KAFKA_ADVERTISED_HOST_NAME: 192.168.142.142 ## 修改:宿主机IP
    KAFKA_ADVERTISED_PORT: 9094 ## 修改:宿主机映射port
    KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://192.168.142.142:9094 ## 修改:宿主机IP
    KAFKA_ZOOKEEPER_CONNECT: "zoo1:2181,zoo2:2181,zoo3:2181"
    volumes:
    - "/www/kafka/kafka2/docker.sock:/var/run/docker.sock"
    - "/www/kafka/kafka2/data/:/kafka"
    networks:
    - docker_net

    kafka3:
    image: wurstmeister/kafka
    restart: unless-stopped
    container_name: kafka3
    ports:
    - "9095:9092"
    external_links:
    - zoo1
    - zoo2
    - zoo3
    environment:
    KAFKA_BROKER_ID: 3
    KAFKA_ADVERTISED_HOST_NAME: 192.168.142.142 ## 修改:宿主机IP
    KAFKA_ADVERTISED_PORT: 9095 ## 修改:宿主机映射port
    KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://192.168.142.142:9095 ## 修改:宿主机IP
    KAFKA_ZOOKEEPER_CONNECT: "zoo1:2181,zoo2:2181,zoo3:2181"
    volumes:
    - "/www/kafka/kafka3/docker.sock:/var/run/docker.sock"
    - "/www/kafka/kafka3/data/:/kafka"
    networks:
    - docker_net

    kafka-manager:
    image: sheepkiller/kafka-manager:latest
    restart: unless-stopped
    container_name: kafka-manager
    hostname: kafka-manager
    ports:
    - "9000:9000"
    links: # 连接本compose文件创建的container
    - kafka1
    - kafka2
    - kafka3
    external_links: # 连接本compose文件以外的container
    - zoo1
    - zoo2
    - zoo3
    environment:
    ZK_HOSTS: zoo1:2181,zoo2:2181,zoo3:2181 ## 修改:宿主机IP
    TZ: CST-8
    networks:
    - docker_net

  • 相关阅读:
    worker与redis网络中断后,worker不再接受任务的异常问题
    Pyecharts 绘制动态流线地图
    MySql存储过程知识了解
    Pyecharts配置项使用
    Pandas一个需求:存在一个列表,需要在一个DataFrame中取到以该列表为索引的数据
    mysql时间与字符串之间相互转换
    map + apply + applymap
    pandas——read_csv
    Python 原生协程------asyncio(选自公众号)
    一道记数题
  • 原文地址:https://www.cnblogs.com/xivzhou/p/14962335.html
Copyright © 2011-2022 走看看