Kafka-King

클러스터 및 토픽 관리

• 클러스터 노드 목록 조회 및 브로커/토픽 설정 동적 구성
• 토픽 생성(일괄 작업 지원) 및 삭제, 복제본 및 파티션 수 지정
• 토픽 파티션 상세 정보(오프셋) 확인 및 파티션 추가

메시지 소비 및 생산

• 컨슈머 클라이언트를 사용하여 지정된 토픽에서 그룹, 크기, 타임아웃 매개변수로 메시지 소비
• 프로듀서 동작 시뮬레이션, 헤더 및 파티션 지정을 포함한 일괄 메시지 전송
• 메시지 상세 정보를 표 형식으로 표시

보안 및 압축 지원

• PLAIN, SSL, SASL, Kerberos, sasl_plaintext 등 다양한 인증 방식 지원
• gzip, lz4, snappy, zstd 압축 및 해제 지원

모니터링 및 검사

• 각 토픽의 총 메시지 수, 커밋된 오프셋, 컨슈머 그룹별 lag 통계
• 토픽 및 파티션 상태 확인
• 컨슈머 그룹 및 개별 컨슈머 조회
• 오프셋 검사 보고서 제공

설치 및 시작

Kafka-King은 winget을 통해 Windows에 간편하게 설치할 수 있습니다. 명령 프롬프트에서 다음 명령을 실행합니다.

winget install --id bronya0.Kafka-King --exact

macOS 사용자의 경우, 앱이 ‘손상됨’으로 표시되면 터미널에서 다음 명령을 실행하여 Gatekeeper 차단을 해제할 수 있습니다.

xattr -dr com.apple.quarantine /Applications/Kafka-King.app

설치 후 시작 메뉴에서 Kafka-King을 실행하고, 연결하려는 Kafka 브로커의 주소와 포트를 입력하여 연결합니다. 좌측 토픽 목록에서 원하는 토픽을 선택하면 우측에 메시지가 표시됩니다.

활용 예시

• Kafka 클러스터의 토픽 목록을 조회하고, 각 토픽의 메시지를 실시간으로 확인하거나 검색할 수 있습니다.
• 간단한 메시지를 생산하거나 소비하여 Kafka 동작을 테스트할 수 있습니다.
• 컨슈머 그룹의 lag을 확인하여 메시지 처리 지연을 모니터링할 수 있습니다.

지원 환경 및 요구사항

Kafka-King은 Windows, macOS, Linux를 지원하며, Windows 7을 제외한 데스크톱 시스템에서 사용할 수 있습니다. x64 아키텍처가 필요하며, Windows에서는 WebView2 런타임이 필요할 수 있습니다. WebView2 오류가 발생하면 Microsoft 공식 웹사이트에서 런타임을 다시 설치하세요.

버전 및 업데이트

v0.30 버전은 2024년 10월 15일에 릴리스되었으며, SSL 및 SASL SSL 지원, SASL 인증 메커니즘 확장, 패키징 로직 개선이 포함됩니다. 최신 릴리스와 변경 내역은 공식 GitHub 저장소에서 확인할 수 있습니다.

라이선스 및 확인사항

Kafka-King은 Apache-2.0 라이선스로 배포됩니다. 사용 전에 Kafka 클러스터의 advertised.listeners 설정이 올바른지 확인하고, 도메인 이름을 사용하는 경우 hosts 파일에 해당 도메인 해석 항목을 추가해야 합니다. SSL 연결이 필요한 경우 TLS를 활성화하고 인증서를 제공해야 합니다. SASL 사용자는 SASL을 활성화하고 적절한 프로토콜을 선택한 후 사용자 이름과 비밀번호를 입력해야 합니다.