본문으로 건너뛰기

소개

1. 모듈 설명

  • 클러스터 내 브로커, 토픽, 파티션 등의 메타데이터와 각 카프카 서버(브로커)의 실시간 메트릭을 모니터링하여 카프카 클러스터의 전반적인 성능 정보를 제공합니다.

2. 패키지 구조

2.1. cfg

  • agent 설정 파일 디렉토리

2.1.1. kafka.conf

  • agent 설정 파일입니다. 옵션 상세는 [설정] 페이지 참조.

2.1.2. cfg.reload

  • 이 파일의 수정 시간이 갱신(touch)되면 런타임에 kafka.conf 옵션을 다시 읽어 반영합니다.

2.2. jre

  • 에이전트 실행을 위한 번들 JRE 17이 위치합니다. (Eclipse Temurin JRE 17)

2.3. lib

2.3.1. exem-kafka-agent.jar

  • 에이전트 실행 JAR 파일입니다.

2.4. log

  • agent 로그 파일이 생성되는 경로입니다.

2.5. start.sh / stop.sh

  • 에이전트 기동/종료 스크립트

2.6. pkg_version.sh / pkg_version.bat

  • 패키지 버전 확인 스크립트입니다.

3. 통신 구조

4. 지원 환경

  • Java 17 이상

5. 수집 방식

  • CLUSTER: Kafka AdminClient API를 통해 클러스터 메타데이터 및 메트릭을 수집합니다.
  • BROKER: JMX(Java Management Extensions)를 통해 브로커 개별 메트릭을 수집합니다.