Kafka 플러그인

Kafka 플러그인은 Apache Kafka cluster를 하나의 Konduo 리소스로 등록하고 broker, controller, topic, partition, consumer group 상태를 운영 evidence로 제공합니다.

특징

bootstrap server를 seed로 사용하고 Kafka metadata에서 broker listener와 cluster id를 검증합니다.
KRaft/controller role, broker inventory, topic/partition 상태, consumer group lag과 offset evidence를 관리 화면에 노출합니다.
Prometheus mapping pack으로 JMX/exporter 계열 metric을 연결합니다.
mixed collection mode에서는 broker metric은 외부 메트릭 소스를 사용하고, consumer group lag은 Kafka Admin API로 직접 수집할 수 있습니다.

등록 전 확인

bootstrap servers, security protocol, SASL, TLS, timeout 설정을 준비합니다.
broker advertised listener가 Konduo backend에서 접근 가능한지 확인합니다.
consumer group lag managed collection을 쓰려면 Admin API 접근 권한과 remote write target을 준비합니다.

운영 팁

bootstrap broker가 내려가도 발견된 broker endpoint가 살아 있으면 일부 운영은 계속 가능할 수 있습니다.
consumer lag은 최신 snapshot 기반 신호이므로 lag 총량, max lag, member 상태, offset movement를 함께 봅니다.
topic partition 변경, reassignment, throttle, ACL/quotas 같은 작업은 확인과 권한 경계 안에서 실행합니다.

Kafka Enterprise 확장

Kafka Enterprise 확장은 Community Kafka 플러그인 위에 MCP descriptor와 이상 징후 규칙 메타데이터를 추가합니다.

특징

MCP catalog에서 monitoring overview, diagnostics, consumer group, security operation, metrics mapping, anomaly rule을 조회합니다.
anomaly rule은 declarative_metric 방식으로 Kafka logical metric을 metric source mapping에 연결합니다.
reassignment, broker drain, replica 변경, topic 변경, message action 같은 mutating workflow는 기존 Konduo API, RBAC, audit 경계를 따릅니다.
bootstrap address는 seed로만 보고, broker inventory와 advertised listener evidence를 함께 해석합니다.

주요 용도

Kafka 운영 상태를 MCP 리소스와 도구로 조회
broker, partition, consumer group 상태를 읽기 중심으로 탐색
Enterprise 이상 징후 규칙 카탈로그 확인
운영 대시보드와 진단 결과를 에이전트 워크플로우에 연결

등록 전 확인

Kafka 기본 연결과 권한은 Community Kafka 플러그인 설정을 따릅니다.
MCP gateway와 관련 권한 프로필이 활성화되어 있어야 MCP descriptor를 사용할 수 있습니다.
이상 징후 규칙은 Enterprise 분석 엔진이 활성화된 환경에서 운영됩니다.

운영 팁

MCP 도구는 운영 조회와 분석 보조 용도로 사용하고, 설정 변경은 Konduo 화면과 승인된 운영 절차를 따릅니다.
이상 징후 규칙은 알림 규칙을 대체하지 않으며, 상관관계 분석과 장애 분석의 보조 신호로 다룹니다.
consumer lag 분석은 lag 총량, max lag, member 상태, offset movement, controller 상태를 함께 봅니다.