[kafka] docker로 kafka, zookeeper, kafka-manager 설치

Prerequisite

https://angellapgm.tistory.com/79

[docker] docker, docker-compose 한번에 설치하고 hello-world 실행하기

docker-compose.yml 파일 작성

사용 image : wurstmeister/zookeeper, wurstmeister/kafka, hlebalbau/kafka-manager:2.0.0.2

version: '3'
services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"
    container_name: zookeeper
    restart: always
  kafka:
    image: wurstmeister/kafka
    ports:
      - "9092:9092"
    environment:
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://10.10.15.112:9092
      KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_CREATE_TOPICS: "hjkim-topic:1:1"
      KAFKA_LOG_CLEANER_ENABLE: "true"
      KAFKA_LOG_CLEANUP_POLICY: "delete"
      KAFKA_LOG_RETENTION_HOURS: 48
      KAFKA_LOG_RETENTION_BYTES: 1073741824
      KAFKA_LOG_SEGMENT_BYTES: 536870912
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock
    depends_on:
      - zookeeper
    container_name: kafka
    restart: always
  kafka-manager:
    container_name: kafka-manager
    image: hlebalbau/kafka-manager:2.0.0.2
    restart: on-failure
    depends_on:
       - kafka
       - zookeeper
    environment:
       ZK_HOSTS: zookeeper:2181
       APPLICATION_SECRET: "random-secret"
       KM_ARGS: -Djava.net.preferIPv4Stack=true
    ports:
      - "9000:9000"

docker-compose ps 확인

root@plaform:/opt# docker-compose ps
    Name                   Command               State                                  Ports
-----------------------------------------------------------------------------------------------------------------------------
kafka           start-kafka.sh                   Up      0.0.0.0:9092->9092/tcp,:::9092->9092/tcp
kafka-manager   /kafka-manager/bin/kafka-m ...   Up      0.0.0.0:9000->9000/tcp,:::9000->9000/tcp
zookeeper       /bin/sh -c /usr/sbin/sshd  ...   Up      0.0.0.0:2181->2181/tcp,:::2181->2181/tcp, 22/tcp, 2888/tcp, 3888/tcp

ip:9000 포트로 접근하여 kafka-manager 실행 확인하기

docker /bin/bash로 상태 확인하기

docker exec -it kafka /bin/bash