Kafdrop 도구를 사용하여 Kafka 클러스터를 관리하는 방법

Kafdrop 도구를 사용하여 Kafka 클러스터를 관리하는 방법

docker-compose.yml 파일 생성

vim docker-compose.yml

services:
  kafdrop:
    image: obsidiandynamics/kafdrop:latest
    restart: always
    container_name: kafdrop
    hostname: kafdrop
    extra_hosts:
      - "node1:192.168.0.111"
      - "node2:192.168.0.112"
      - "node3:192.168.0.113"
    environment:
      - KAFKA_BROKERCONNECT=node1:9092,node2:9092,node3:9092
    ports:
      - "9999:9000"
    networks:
      - kafka-network

networks:
  kafka-network:
    driver: bridge

Kafdrop 시작

docker compose up -d

Kafdrop 접근

http://server-ip:9999

728x90

Kafdrop 사용

주제 관리: Kafdrop UI를 통해 Kafka 주제를 생성하고 삭제할 수 있습니다.

메시지 소비: 각 주제에 대해 메시지를 소비하고 내용을 확인할 수 있습니다.

소비자 그룹 보기: 소비자 그룹의 상태와 오프셋을 확인할 수 있습니다.

kafdrop_brokers

kafdrop_topic_test-topic

kafdrop_topic-messages

Kafdrop 로그 확인

docker compose logs kafdrop

 

Docker Compose를 통해 Kafdrop을 사용하여 Kafka 클러스터를 효과적으로 관리할 수 있습니다.

 

참고URL

- github : Kafdrop