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