[kafka] 주키퍼에서 카프카 토픽 확인하는 방법

1. 도커 컴포즈 파일 작성

docker-compose.yml

version: '3'

services:

  # wurstmeister/zookeeper:3.4.6
  zookeeper:
    hostname: zookeeper
    container_name: zookeeper
    image: wurstmeister/zookeeper:3.4.6
    ports:
      - "2181:2181"

  # wurstmeister/kafka:2.13-2.8.1
  kafka:
    hostname: kafka
    container_name: kafka
    image: wurstmeister/kafka:2.13-2.8.1
    environment:
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092
      KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092
      KAFKA_ADVERTISED_HOST_NAME: 127.0.0.1
      KAFKA_ADVERTISED_PORT: 9092
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_CREATE_TOPICS: "test:1:1"
    ports:
      - "9092:9092"
    depends_on:
      - zookeeper

 

도커 컴포즈 실행 및 실행상태 확인

docker-compose up -d

docker ps

 

2. 카프카 접속

카프카에 접속해보자

docker exec -it kafka bash

토픽 리스트 확인

kafka-topics.sh --list --bootstrap-server kafka:9092

테스트를 위해 topic1, topic2, topic3 이라는 토픽을 만들어보자

kafka-topics.sh --create --bootstrap-server kafka:9092 --replication-factor 1 --partitions 1 --topic topic1
kafka-topics.sh --create --bootstrap-server kafka:9092 --replication-factor 1 --partitions 1 --topic topic2
kafka-topics.sh --create --bootstrap-server kafka:9092 --replication-factor 1 --partitions 1 --topic topic3

토픽 리스트 조회

kafka-topics.sh --list --bootstrap-server kafka:9092

이제 카프카 컨테이너를 종료하고

주키퍼 컨테이너로 접속해보자

exit

docker exec -it zookeeper bash

 

주키퍼 명령어가 모여있는 bin폴더로 들어가보자

ls
cd bin
ls

 

zkCli.sh를 실행

./zkCli.sh

 

카프카 토픽 확인하는 명령어를 입력해보자

우리는 카프카에 test, topic1, topic2, topic3 이라는 토픽이 있다.

ls /brokers/topics

카프카에 있는 토픽 리스트들이 조회된다.