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