RocketMQ¶

RocketMQ のメトリクス表示。プロデューサーの TPS/メッセージサイズ、コンシューマーの TPS/メッセージサイズ、メッセージ蓄積、topic 情報などを含む

インストールと設定¶

説明: 例では Linux 版を CentOS Linux release 7.8.2003 (Core) とし、Windows 版は対応する設定ファイルを変更してください

対応 OS: Linux / Windows
サーバーに rocketmq-exporter をインストール

exporter のインストール¶

rocketmq-exporter を取得

git clone https://github.com/apache/rocketmq-exporter.git

インストールディレクトリへ移動

cd rocketmq-exporter/

ビルドしてインストールパッケージを作成（どちらか 1 つで可）

（1）jar パッケージをビルドする方法

mvn clean install

ビルド完了後、target ディレクトリへ移動

cd target

jar パッケージを起動（コマンド中の nameserverip アドレスを置き換えてください）

nohup java -jar target/rocketmq-exporter-0.0.2-SNAPSHOT.jar --rocketmq.config.namesrvAddr=nameserverip:9876 &

（2）Docker イメージをビルドする方法

mvn package -Dmaven.test.skip=true docker:build

イメージを使って Docker を起動（コマンド中の nameserverip アドレスを置き換えてください）

docker run -d --net="host" --name rocketmq-exporter -p 5557:5557 docker.io/rocketmq-exporter --rocketmq.config.namesrvAddr=nameserverip:9876

rocketmq-exporter が正常かテスト

curl http://127.0.0.1:5557/metrics

メトリクス収集¶

DataKit の Prometheus プラグインを有効化し、sample ファイルをコピー

cd /usr/local/datakit/conf.d/samples
cp prom.conf.sample prom.conf

設定ファイル prom.conf を変更

主なパラメータの説明

urls：exporter のアドレス。内部ネットワークのアドレスを推奨。リモート収集ではパブリックネットワークも使用可
ignore_req_err：URL へのリクエストエラーを無視
source：収集器の別名
metrics_types：既定では counter と gauge 型のメトリクスのみ収集
interval：収集頻度

[[inputs.prom]]
  urls = ["http://127.0.0.1:5557/metrics"]
  ignore_req_err = false
  source = "prom"
# metric_types は空を選択する必要があります。rocketmq-exporter ではデータ型が指定されていません
  metric_types = []
  interval = "60s"

DataKit を再起動

メトリクス¶

メトリクス	説明	データ型
`rocketmq_broker_tps`	broker の 1 秒あたりの生産メッセージ数	int
`rocketmq_broker_qps`	broker の 1 秒あたりの消費メッセージ数	int
`rocketmq_producer_tps`	ある topic の 1 秒あたりの生産メッセージ数	int
`rocketmq_producer_put_size`	ある topic の 1 秒あたりの生産メッセージサイズ（バイト）	int
`rocketmq_producer_offset`	ある topic の生産メッセージの進捗	int
`rocketmq_consumer_tps`	あるコンシューマーグループの 1 秒あたりの消費メッセージ数	int
`rocketmq_consumer_get_size`	あるコンシューマーグループの 1 秒あたりの消費メッセージサイズ（バイト）	int
`rocketmq_consumer_offset`	あるコンシューマーグループの消費メッセージの進捗	int
`rocketmq_group_get_latency_by_storetime`	あるコンシューマーグループの消費遅延時間	int
`rocketmq_message_accumulati`	メッセージ蓄積量	int

さらに読む¶

RocketMQ Exporter Git コード