MQTT ブリッジ（ディスクキュー付き）

このプラグインを使用すると、ローカルの MQTT メッセージを別の MQTT ブローカーに転送し、ディスクバッファによってレジリエンスを向上させることができます。

特長

ブリッジごとのディスクバッファリング。
リモートブローカーが利用できない場合の自動リトライ。
${topic} を使ったトピック書き換え対応。
1つのプラグインで複数のブリッジを管理可能。
設定の更新はブリッジ単位で適用（変更のないブリッジは稼働継続）。

動作概要

ローカルのパブリッシュを各ブリッジの filter_topic と照合。
一致したメッセージをディスクキューのパーティションに追加。
キューに溜まったメッセージをリモートブローカーにパブリッシュ。
ネットワークや接続障害でパブリッシュに失敗した場合は自動リトライ。
キューパーティションが queue.max_total_bytes を超えた場合、そのパーティション内の最も古いレコードが破棄される。

設定

EMQX ダッシュボード（推奨）またはプラグイン設定ファイルから設定可能です。

本番環境では、まず1つのブリッジでトラフィックを検証し、その後スケールアウトしてください。

設定ファイルの場所

関連する設定ファイルは以下の2種類があります：

インストールされたプラグインパッケージ内のデフォルトファイル：
- Docker インストール例（バージョン 0.2.0）： /opt/emqx/plugins/emqx_bridge_mqtt_dq-0.2.0/emqx_bridge_mqtt_dq-0.2.0/priv/config.hocon
- deb/rpm インストール例（バージョン 0.2.0）： /usr/lib/emqx/plugins/emqx_bridge_mqtt_dq-0.2.0/emqx_bridge_mqtt_dq-0.2.0/priv/config.hocon
EMQX がダッシュボードや API 経由で設定保存後に管理する永続化プラグイン設定ファイル：
- Docker： /opt/emqx/data/plugins/emqx_bridge_mqtt_dq/config.hocon
- deb/rpm： /var/lib/emqx/plugins/emqx_bridge_mqtt_dq/config.hocon

priv/config.hocon はパッケージに含まれるデフォルトテンプレートです。
data/plugins/.../config.hocon は EMQX がプラグイン設定変更を保存後に使用する永続化設定ファイルの場所です。

クイックスタート（ダッシュボード）

プラグインを有効化します。
remotes に再利用可能なリモートを1つ追加します。
bridges にブリッジを1つ追加します。
remote、filter_topic、remote_topic を設定します。
保存してリモート配信を検証します。
ベースライン検証後にキューやプールの設定を調整します。

例

hocon

bridges {
  to-cloud {
    enable = true
    remote = cloud
    proto_ver = "v4"
    keepalive_s = 60
    pool_size = 4
    filter_topic = "devices/#"
    remote_topic = "fwd/${topic}"
    remote_qos = "${qos}"
    remote_retain = "${retain}"
    queue {
      seg_bytes = "100MB"
      max_total_bytes = "1GB"
    }
  }
}

remotes {
  cloud {
    server = "cloud-broker.example.com:8883"
    username = "bridge_user"
    password = "secret"
    ssl {
      enable = true
      verify = verify_none
      # cacertfile = "/path/to/ca.pem"
      # certfile = "/path/to/client-cert.pem"
      # keyfile = "/path/to/client-key.pem"
    }
  }
}

環境変数の置換

設定ファイル内の任意の文字列値は ${EMQXDQ_*} 形式で OS の環境変数を参照できます。
EMQXDQ_ プレフィックス付きの変数のみが解決されます。
${topic} のような他の ${...} パターンはそのまま残ります。
値全体がプレースホルダーである必要があり、部分的な置換（例: "prefix-${EMQXDQ_VAR}-suffix"）はサポートされません。

制限: ${EMQXDQ_*} の置換は文字列型のフィールド（例：server、username、password）のみ対応し、
ブール型（enable）、整数型（pool_size、keepalive_s）には使用できません。

例：

hocon

remotes {
  cloud {
    server = "${EMQXDQ_REMOTE_SERVER}"
    username = "${EMQXDQ_REMOTE_USER}"
    password = "${EMQXDQ_REMOTE_PASSWORD}"
  }
}

環境変数が設定されていない場合、プラグインはエラーをログに出力し、元の ${EMQXDQ_...} 文字列をそのまま値として保持します。
これにより接続失敗（例："${EMQXDQ_REMOTE_SERVER}" への接続試行）が発生し、ログやステータス API で誤設定が明示されます。

警告: 動的設定更新とノードローカル環境変数について
環境変数は設定を解析するノードでのみ解決されます。
EMQX ダッシュボード、REST API、CLI でプラグイン設定を更新すると、設定テキストが永続化され、クラスター内のすべてのノードで再解析されます。
ノードごとに環境変数の値が異なる（または未設定）場合、ノードごとに異なる実効設定になります。
そのため、クラスター内のすべてのノードで同じ環境変数が設定されている場合を除き、ダッシュボードや API、CLI での ${EMQXDQ_...} 置換は避けてください。
ノードローカルのシークレットは、設定ファイルを直接編集してプラグインをリロードするか、Kubernetes ConfigMaps/Secrets のような一貫したシークレット注入機構を利用してください。

設定リファレンス

トップレベル

フィールド	型	デフォルト	説明
`bridges`	map	`{}`	ブリッジ名をキーとしたブリッジ設定のマップ。
`remotes`	map	`{}`	再利用可能なリモートブローカー定義のマップ。

ブリッジ (`bridges.<name>`)

フィールド	型	デフォルト	説明
`enable`	boolean	`true`	このブリッジを有効化または無効化します。
`remote`	string	—	`remotes` 内のリモートブローカー定義名。
`proto_ver`	string	`"v4"`	MQTT プロトコルバージョン：`v3`、`v4`、`v5` のいずれか。
`clientid_prefix`	string	`"emqx-dq-<name>-"`	自動生成される MQTT クライアントIDのプレフィックス。各接続にユニークなインデックスが付加されます（例：`emqx-dq-mybridge-0`）。空文字でデフォルトを使用可能。
`keepalive_s`	integer	`60`	MQTT のキープアライブ間隔（秒）。
`pool_size`	integer	`4`	リモートブローカーへの MQTT 接続数。
`buffer_pool_size`	integer	`4`	ブリッジごとのディスクキューバッファワーカー数。以下の注意点を参照してください。
`filter_topic`	string	—	ローカルトピックのフィルタパターン。`+` と `#` のワイルドカードをサポート。
`remote_topic`	string	—	転送先のトピックテンプレート。元のトピックは `${topic}` で参照可能。
`enqueue_timeout_ms`	integer	`5000`	ディスクキューへの書き込み確認を待つ最大時間（ミリ秒）。QoS > 0 の場合のみ適用。QoS 0 は常に非同期。
`max_inflight`	integer	`32`	リモートブローカーへの未アックメッセージの最大数。ディスクキューからのバッチポップサイズや emqtt の送信ウィンドウを制御。
`remote_qos`	string	`"${qos}"`	リモートブローカーへのパブリッシュ時の QoS レベル（`"0"`、`"1"`、`"2"`）。デフォルトの `"${qos}"` は元メッセージの QoS を保持。
`remote_retain`	string	`"${retain}"`	リモートブローカーへのパブリッシュ時のリテインフラグ（`"true"`、`"false"`）。デフォルトの `"${retain}"` は元メッセージのリテインフラグを保持。
`max_publish_retries`	integer	`-1`	メッセージごとのパブリッシュリトライ回数。`-1` は無限リトライ。失敗した PUBACK や接続切断ごとに1回消費。

リモート (`remotes.<name>`)

フィールド	型	デフォルト	説明
`server`	string	—	リモート MQTT ブローカーのアドレス（`host:port`）。
`username`	string	`""`	リモートブローカー認証用ユーザー名。
`password`	string	`""`	リモートブローカー認証用パスワード。
`ssl.enable`	boolean	`false`	リモートブローカー接続で SSL/TLS を有効化。
`ssl.verify`	string	`verify_none`	TLS 検証モード。サポート値：`verify_none`、`verify_peer`。
`ssl.sni`	string	サーバーホスト名	TLS Server Name Indication。デフォルトはサーバーホスト名。`"disable"` で SNI 無効化。
`ssl.cacertfile`	string	—	リモートブローカー証明書検証用 CA 証明書ファイル。
`ssl.certfile`	string	—	相互 TLS 認証用クライアント証明書ファイル。
`ssl.keyfile`	string	—	相互 TLS 認証用クライアント秘密鍵ファイル。

キュー

フィールド	型	デフォルト	説明
`queue.base_dir`	string	`"emqx_bridge_mqtt_dq"`	ディスクキューのセグメントファイルのベースディレクトリ。ブリッジ名とパーティションインデックスが自動付加されます（例：`<base_dir>/<bridge_name>/<index>`）。相対パスは EMQX の `data_dir` 基準で解決。絶対パスはそのまま使用。
`queue_seg_bytes`	string	`"100MB"`	キューセグメントファイルの最大サイズ。
`queue.max_total_bytes`	string	`"1GB"`	パーティションごとの最大ディスクキューサイズ。各ブリッジは `buffer_pool_size` 個のパーティションを使用（デフォルト4）。最大合計ディスク使用量は `buffer_pool_size` × この値。超過時は最古メッセージを破棄。

トピックテンプレート

remote_topic フィールドは ${topic} プレースホルダーをサポートし、転送時に元のパブリッシュトピックに置換されます。

例：

remote_topic = "${topic}"：元のトピックをそのまま転送。
remote_topic = "forwarded/${topic}"：プレフィックスを付加。
remote_topic = "region1/${topic}"：リージョンのネームスペースを追加。

remote_topic はキューからメッセージを送信する際に適用されます。このフィールドを変更した場合、該当ブリッジを再起動後にキュー内のメッセージは新しいテンプレートを使用します。

REST API

プラグインは EMQX プラグイン API ベースパス以下に4つのエンドポイントを公開しています：

GET /api/v5/plugin_api/emqx_bridge_mqtt_dq/metrics：Prometheus テキスト形式
GET /api/v5/plugin_api/emqx_bridge_mqtt_dq/stats：JSON ダッシュボードスナップショット
GET /api/v5/plugin_api/emqx_bridge_mqtt_dq/stats/<bridge>：特定ブリッジのみ
GET /api/v5/plugin_api/emqx_bridge_mqtt_dq/status：プラグイン／クラスターのヘルスサマリー

すべての JSON エンドポイントは application/json; charset=utf-8 を返します。

JSON API はクラスター集約型です。ノードが利用不可またはタイムアウトした場合でもベストエフォートでデータを返しますが、レスポンスにはクラスターの完全性メタデータが含まれます。

例：

bash

curl -u admin:public \
  http://127.0.0.1:18083/api/v5/plugin_api/emqx_bridge_mqtt_dq/metrics

bash

curl -u admin:public \
  http://127.0.0.1:18083/api/v5/plugin_api/emqx_bridge_mqtt_dq/stats

`/stats` レスポンス構造

/stats のレスポンスボディは以下を含みます：

cluster：クラスターの完全性と失敗ノード情報
uptime_seconds：応答ノード間で観測された最大プラグインアップタイム
summary：全ブリッジの合計値
bridges：設定された各ブリッジの情報

例：

json

{
  "cluster": {
    "complete": true,
    "responded_nodes": ["emqx@127.0.0.1"],
    "failed_nodes": [],
    "timeout_ms": 5000
  },
  "uptime_seconds": 123,
  "summary": {
    "bridge_count": 1,
    "running_bridge_count": 1,
    "buffered": 12,
    "backlog": 3,
    "inflight": 8,
    "enqueue": 1000,
    "dequeue": 995,
    "publish": 990,
    "drop": 5
  },
  "bridges": [
    {
      "name": "to-cloud",
      "config_state": "enabled",
      "runtime_state": "running",
      "status": "ok",
      "status_reason": null,
      "enqueue": 1000,
      "dequeue": 995,
      "publish": 990,
      "drop": 5,
      "retried_by_reason": {
        "connect_failed": 2,
        "reason_code": 3
      },
      "buffered": 12,
      "backlog": 3,
      "inflight": 8,
      "buffers": [
        {
          "bridge": "to-cloud",
          "index": 0,
          "status": "running",
          "buffered": 12
        }
      ],
      "connectors": [
        {
          "bridge": "to-cloud",
          "index": 0,
          "status": "connected",
          "backlog": 3,
          "inflight": 8
        }
      ]
    }
  ]
}

GET /stats/<bridge> は以下を返します：

json

{
  "cluster": {
    "complete": true,
    "responded_nodes": ["emqx@127.0.0.1"],
    "failed_nodes": [],
    "timeout_ms": 5000
  },
  "bridge": {
    "name": "to-cloud",
    "config_state": "enabled",
    "runtime_state": "running",
    "status": "ok"
  }
}

ブリッジが現在の設定に存在しない場合、API は 404 を返します。

GET /status は簡潔なヘルスビューを返します：

json

{
  "plugin": "emqx_bridge_mqtt_dq",
  "cluster": {
    "complete": true,
    "responded_nodes": ["emqx@127.0.0.1"],
    "failed_nodes": [],
    "timeout_ms": 5000
  },
  "status": "ok",
  "bridge_count": 1
}

/metrics エンドポイントはクラスター集約された Prometheus テキスト形式のメトリクスを返します。例：

emqx_bridge_mqtt_dq_uptime_seconds
emqx_bridge_mqtt_dq_bridge_enqueue_total{bridge="..."}
emqx_bridge_mqtt_dq_bridge_dequeue_total{bridge="..."}
emqx_bridge_mqtt_dq_bridge_publish_total{bridge="..."}
emqx_bridge_mqtt_dq_bridge_drop_total{bridge="..."}
emqx_bridge_mqtt_dq_bridge_status{bridge="...",status="..."}
emqx_bridge_mqtt_dq_bridge_retry_reason_total{bridge="...",reason="..."}
emqx_bridge_mqtt_dq_buffer_buffered{bridge="...",index="..."}
emqx_bridge_mqtt_dq_connector_backlog{bridge="...",index="..."}
emqx_bridge_mqtt_dq_connector_inflight{bridge="...",index="..."}

メトリクスの意味

ブリッジメトリクス

enqueue：ローカルでブリッジのエンキュー経路に受け入れたメッセージ数
dequeue：ローカルキューから永続的に削除されたメッセージ数
publish：リモートブローカーに正常にパブリッシュされたメッセージ数
drop：キュー内で破棄されたメッセージ数
retried_by_reason：リトライ理由別のリトライ回数
config_state：設定からの望ましいブリッジ状態（enabled または disabled）
runtime_state：実際のワーカー／ストレージ状態（running、degraded、purged）
status：運用者向けのブリッジヘルス状態（ok、partial、disconnected、disabled、error）

現在のリトライ理由：

reason_code：リモートブローカーが非成功 MQTT 理由コードを返しリトライされた
connect_failed：接続またはパブリッシュ失敗でリトライされた
timeout：タイムアウトによるリトライ分類
connection_lost：関連クライアントプロセス終了によりインフライトメッセージがリトライ用に回収された
other：分類不能なリトライ理由のフォールバック

ブリッジが完全にドレインされた後は、以下が成立します：

enqueue = dequeue = publish + drop

バッファメトリクス

buffered：該当する永続キューパーティションに現在格納されているメッセージ数
バッファ行の status：ワーカーが存在すれば running、そうでなければ missing

このゲージは replayq:open/1 の直後に更新されるため、永続化されたディスク上のメッセージは新規トラフィック到着前でも確認可能です。

コネクタメトリクス

backlog：emqtt に送出待ちのコネクタバックログキュー内メッセージ数
inflight：emqtt に渡され完了待ちのメッセージ数
コネクタ行の status：connected、disconnected、partial、missing、unknown のいずれか

設定変更時の挙動

設定更新はブリッジ単位で適用されます：

変更されたブリッジは再起動されます。
削除されたブリッジは停止します。
無効化されたブリッジは停止し、キューディレクトリをパージします。
新規ブリッジは起動します。
変更のないブリッジは稼働継続します。

プラグイン全体は設定更新ごとに再起動されません。
ただし再起動される各ブリッジは、マッチするメッセージがドロップされる可能性のある短時間のハンドオーバーウィンドウがあります。
ブリッジに影響する変更はトラフィックの少ない時間帯に適用してください。

設定変更前の注意

影響を受けるブリッジを特定。
トラフィックが少ない時間帯に適用。
ダッシュボードのステータスやログで再起動・再接続エラーを監視。
重要なパイプラインは変更後にエンドツーエンドの配信検証を実施。

`queue.base_dir` の変更

有効なブリッジで queue.base_dir を変更すると、新しいディレクトリでブリッジが再起動されます。
実際のキューパスは <base_dir>/<bridge_name>/<index> です。
古いディレクトリは自動で削除されず、ディスク上に孤立データとして残ります。
不要なら新しいパスでブリッジが稼働していることを確認後に手動で削除してください。

`buffer_pool_size` の変更

buffer_pool_size はブリッジごとのディスクキューパーティション数を制御します。
メッセージは erlang:phash2(Topic, buffer_pool_size) によってパーティションに割り当てられます。
この値の変更には重要な副作用があります：

プール縮小（例：8 → 4）
新サイズ以上のインデックスのパーティションは消費されなくなります。
古いファイルは queue.base_dir 配下に残り手動でのクリーンアップが必要です。
プール拡大（例：4 → 8）
ハッシュ空間が変わるため、以前パーティション N に割り当てられていたトピックが新たにパーティション M に割り当てられます。
古いパーティションに溜まったメッセージは順序を保って配信されますが、同じトピックの新規メッセージは別パーティションに行くため、トピック単位のエンドツーエンド順序が一時的に崩れます。
ブリッジ単位のドロップウィンドウ
buffer_pool_size の変更でブリッジが再起動されるため、ハンドオーバー中にインフライトメッセージがドロップされる可能性があります。

メッセージ配信保証

このプラグインは通常動作下で 少なくとも1回 配信を保証し、
持続的な障害時は ベストエフォート 配信となります。
以下のシナリオでメッセージが失われる可能性があります。

ディスクキューオーバーフロー

キューパーティションが queue.max_total_bytes を超えると、最も古いメッセージが静かに破棄されます。
警告ログ (mqtt_dq_buffer_overflow) は定期的に出力されます（メッセージごとではありません）。

対策：queue.max_total_bytes を増やす、buffer_pool_size を増やして負荷分散、またはメッセージスループットを減らす。

リモートブローカーがパブリッシュを拒否

リモートブローカーが PUBACK（QoS 1）や PUBREC（QoS 2）で非成功の MQTT 理由コードを返した場合、コネクターは最大3回リトライします。
すべてのリトライが失敗するとメッセージは破棄され、警告ログ (mqtt_dq_publish_dropped) が出力されます。

主な拒否理由コード：

コード	意味（MQTT 5.0）
16	サブスクライバーが存在しない
128	未指定のエラー
131	実装固有のエラー
135	認可されていない
144	トピック名が無効
145	パケット識別子が使用中
151	クォータ超過

注：理由コード 0（成功）と 16（サブスクライバーなし）は成功扱いでリトライされません。

対策：リモートブローカーの ACL とトピックポリシーを確認し、ログの理由コードを調査してください。

繰り返しの接続障害

リモートブローカーへの接続が切断されるたびに、未アックメッセージはリトライ回数を1回消費します。
3回の接続障害が累積し成功配信がない場合、メッセージは破棄されます。

例：ネットワーク障害中にパブリッシュされたメッセージ

ローカルにキューイング（リトライカウンター=3）
リモート再接続、送信：ACK前に切断（カウンター=2）
再接続、再送：切断（カウンター=1）
再接続、再送：拒否または切断（カウンター=0）
メッセージ破棄、警告ログ出力

対策：リモートブローカーが繰り返し接続不能になる原因を調査してください。
一時的なネットワーク断は透過的に処理されますが、持続的な不安定性が問題です。

エンキュー時のバックプレッシャー（QoS > 0 のローカルパブリッシュ）

QoS 1 または 2 のクライアントがブリッジにマッチするメッセージをパブリッシュすると、プラグインはバッファワーカーのメールボックスにメッセージを送信し、ディスク書き込み確認まで最大 enqueue_timeout_ms（デフォルト5000ms）待機してセッションプロセスをブロックします。

このタイムアウトが発生してもメッセージ自体は失われません。
すでにバッファワーカーの Erlang メールボックスに存在し、最終的にディスクキューに書き込まれます。
タイムアウトはローカルパブリッシュ経路のブロック時間を制御するだけです。

理由：message.publish フックは MQTT セッションプロセス内で実行されます。
フックがブロック中はそのクライアントの他メッセージ処理が停止します。
バッファワーカーが遅い（ディスク I/O ストールやメールボックスのバックログ増加）場合、タイムアウトはクライアントセッションの無限停止を防ぎます。

タイムアウト発生時の挙動：

セッションプロセスは待機をやめて通常処理を継続。
クライアントには通常通り PUBACK/PUBREC が返され、エラーは発生しない。
警告ログ (mqtt_dq_enqueue_timeout) を出力。
メッセージはバッファワーカーのメールボックスに残り、追いついた時点でディスクキューに書き込まれる。

リスクは間接的です。バッファワーカーが継続的に遅延するとメールボックスが無制限に増加し、メモリ使用量が増大します。
これはブリッジが受信メッセージレートに追いつけていない兆候です。

対策：buffer_pool_size を増やして負荷分散、queue.base_dir に高速ストレージを使用、またはマッチするトピックのメッセージレートを下げてください。

注：QoS 0 のローカルパブリッシュは常に非同期でエンキューされ、パブリッシュセッションにバックプレッシャーはかかりません。

ブリッジ再起動時のウィンドウ

ブリッジが再起動（設定変更、プラグインリロード、有効化/無効化切り替え）される際、マッチするメッセージが一時的に捕捉されない短いウィンドウがあります。

対策：設定変更はトラフィックの少ない時間帯に適用してください。

QoS 0 の TCP レベル配信

リモートブローカーへの QoS 0 パブリッシュは、メッセージがローカルの TCP 送信バッファに到達した時点で配信成功とみなされます。
リモートブローカーが TCP スタックで受け入れた後にクラッシュすると、メッセージは失われる可能性がありますが、コネクターにはエラーが返りません。

これは MQTT QoS 0 の仕様であり、本プラグイン固有の問題ではありません。

運用上の注意

永続化

バッファされたメッセージは以下の状況で保持されます：

EMQX ノードの再起動
プラグインのリロードやアップグレード
リモートブローカーへの一時的なネットワーク障害

キュー制限

キュー使用量が queue.max_total_bytes を超えたパーティションでは、最古のメッセージが破棄されます。警告ログが出力されます。

プールサイズ設定

各バッファワーカーは BufferIndex rem pool_size により正確に1つのコネクターに割り当てられます。均等な負荷分散のため：

buffer_pool_size は pool_size 以上であるべきです。
buffer_pool_size は pool_size の倍数であるべきです（例：buffer_pool_size mod pool_size = 0）。

良い例：pool_size = 4, buffer_pool_size = 4（1:1）、pool_size = 4, buffer_pool_size = 8（2:1）。
悪い例：pool_size = 4, buffer_pool_size = 5 はコネクター0が2つのバッファを担当し、他は1つでスループットが不均一になります。

コネクターが切断されると、割り当てられたバッファワーカーは一時停止し、再接続後に自動再開します。

順序性

安定したブリッジ設定下ではトピック単位の順序は保持されます。
buffer_pool_size を変更すると、一時的に順序が乱れることがあります（前述の通り）。

パブリッシャーのアック挙動（QoS 1/2）

ブリッジにマッチするメッセージについて：

パブリッシュクライアントへの PUBACK（QoS 1）や PUBREC（QoS 2）は、EMQX がディスクキューへのエンキュー確認（enqueue_timeout_ms）を待つ間、遅延する可能性があります。
エンキュー待ちがタイムアウトしても、EMQX はクライアントのパブリッシュフローを完了します。
クライアントはディスクキューエンキュータイムアウトによるエラーを受け取りません。

ダウンロード

各 EMQX リリースの tarball：

EMQX バージョン	プラグインバージョン	パッケージ
6.2.0	0.5.1	emqx_bridge_mqtt_dq-0.5.1.tar.gz

Kubernetes

EMQX Operator

EMQX クラスター管理

API リファレンス

パスワード認証

監視

アクセスコントロール

統合

管理

Prometheus との統合

OpenTelemetry との統合

エンドツーエンドトレース

プラグインカタログ

JT/T 808 ゲートウェイ

GB/T 32960 ゲートウェイ

Volcengine RTC

シナリオ

GPT-Realtime

MQTT ブリッジ（ディスクキュー付き） ​

特長 ​

動作概要 ​

設定 ​

設定ファイルの場所 ​

クイックスタート（ダッシュボード） ​

例 ​

環境変数の置換 ​

設定リファレンス ​

トップレベル ​

ブリッジ (bridges.<name>) ​

リモート (remotes.<name>) ​

キュー ​

トピックテンプレート ​

REST API ​

/stats レスポンス構造 ​

メトリクスの意味 ​

ブリッジメトリクス ​

バッファメトリクス ​

コネクタメトリクス ​

設定変更時の挙動 ​

設定変更前の注意 ​

queue.base_dir の変更 ​

buffer_pool_size の変更 ​

メッセージ配信保証 ​

ディスクキューオーバーフロー ​

リモートブローカーがパブリッシュを拒否 ​

繰り返しの接続障害 ​

エンキュー時のバックプレッシャー（QoS > 0 のローカルパブリッシュ） ​

ブリッジ再起動時のウィンドウ ​

QoS 0 の TCP レベル配信 ​

運用上の注意 ​

永続化 ​

キュー制限 ​

プールサイズ設定 ​

順序性 ​

パブリッシャーのアック挙動（QoS 1/2） ​

ダウンロード ​

MQTT ブリッジ（ディスクキュー付き）

特長

動作概要

設定

設定ファイルの場所

クイックスタート（ダッシュボード）

例

環境変数の置換

設定リファレンス

トップレベル

ブリッジ (`bridges.<name>`)

リモート (`remotes.<name>`)

キュー

トピックテンプレート

REST API

`/stats` レスポンス構造

メトリクスの意味

ブリッジメトリクス

バッファメトリクス

コネクタメトリクス

設定変更時の挙動

設定変更前の注意

`queue.base_dir` の変更

`buffer_pool_size` の変更

メッセージ配信保証

ディスクキューオーバーフロー

リモートブローカーがパブリッシュを拒否

繰り返しの接続障害

エンキュー時のバックプレッシャー（QoS > 0 のローカルパブリッシュ）

ブリッジ再起動時のウィンドウ

QoS 0 の TCP レベル配信

運用上の注意

永続化

キュー制限

プールサイズ設定

順序性

パブリッシャーのアック挙動（QoS 1/2）

ダウンロード