Apache Kafka 消費者滯後 Runbook

Apache Kafka 消費者滯後 Runbook 是做什麼的？

使用 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 # 執行標記為不穩定的測試

• 來源：https://github.com/apache/kafka

• 從上游文件提取：https://raw.githubusercontent.com/apache/kafka/HEAD/README.md

文件

• https://kafka.apache.org/documentation/

來源

• Agent Skill Exchange