紹介

1. モジュール説明​

• クラスタ内のブローカー、トピック、パーティションなどのメタデータと各Kafkaサーバー(ブローカー)のリアルタイムメトリックをモニタリングし、Kafkaクラスタの全般的な性能情報を提供します。

2. パッケージ構造​

2.1. cfg​

• agent設定ファイルディレクトリ

2.1.1. kafka.conf​

• agent設定ファイルです。オプションの詳細は[設定]ページを参照。

2.1.2. cfg.reload​

• このファイルの修正時刻が更新(touch)されると、ランタイムにkafka.confオプションを再読み込みして反映します。

2.2. jre​

• エージェント実行のためのバンドルJRE 17が配置されています。(Eclipse Temurin JRE 17)

2.3. lib​

2.3.1. exem-kafka-agent.jar​

• エージェント実行JARファイルです。

2.4. log​

• agentログファイルが生成される経路です。

2.5. start.sh / stop.sh​

• エージェント起動/終了スクリプト

2.6. pkg_version.sh / pkg_version.bat​

• パッケージバージョン確認スクリプトです。

3. 通信構造​

4. サポート環境​

• Java 17以上

5. 収集方式​

• CLUSTER: Kafka AdminClient APIを通じてクラスタのメタデータ及びメトリックを収集します。
• BROKER: JMX(Java Management Extensions)を通じてブローカー個別メトリックを収集します。