Apache Kafka 컨슈머 랙 런북은(는) 무엇을 하나요?
Kafka AdminClient API와 Confluent Metrics API를 통해 노출된 JMX 메트릭을 사용하여 Kafka 컨슈머 그룹 랙을 진단합니다. 느린 컨슈머, 토픽 파티션 핫스팟, 브로커 리밸런스 폭풍을 식별하여 랙 증가의 원인을 파악합니다. fetch.min.bytes, max.poll.records, 파티션 수를 조정하는 단계별 런북을 제공합니다.
전제 조건
Java
설치
사용자 환경에 맞는 업스트림 설치 또는 설정 경로를 사용하십시오:
- docker run -p 9092:9092 apache/kafka:latest
업스트림의 요구 사항 및 주의 사항:
- Docker 이미지 사용:
- 자세한 내용은 docker/README.md를 참조하십시오.
기본 사용법 또는 시작 노트:
-
JAR 빌드 및 실행
-
단위/통합 테스트 실행
-
./gradlew test -Pkafka.test.run.flaky=true # 플래키(flaky)로 표시된 테스트 실행
-
업스트림 문서에서 추출: https://raw.githubusercontent.com/apache/kafka/HEAD/README.md