ConsumeMQTT 2025.5.31.15¶

ブローカー URI

MQTT ブローカーへの接続に使用する URI (複数可) (例: tcp://localhost:1883)。「tcp」、「ssl」、「ws」、「wss」スキームがサポートされています。'ssl' を使用するには、 SSL Context Service プロパティをセットする必要があります。カンマ区切りの URI リスト (例えば、tcp://localhost:1883,tcp://localhost:1884) がセットされている場合、プロセッサーは接続失敗時にラウンドロビンアルゴリズムを使用してブローカーに接続します。

接続タイムアウト（秒）

MQTT サーバーへのネットワーク接続が確立されるまで、クライアントが待機する最大時間間隔。デフォルトのタイムアウトは30秒です。値0はタイムアウト処理を無効にし、クライアントはネットワーク接続が成功するか失敗するまで待ちます。

Keep Alive Interval (秒)

メッセージの送受信間の最大時間間隔を定義します。これにより、 TCP/IP のタイムアウトを待つことなく、クライアントがサーバーが利用できなくなったことを検知できるようになります。クライアントはキープアライブ期間内に少なくとも1つのメッセージがネットワークを通過するようにします。その期間中にデータ関連のメッセージがない場合、クライアントは非常に小容量の「Ping」メッセージを送信し、サーバーはそれを確認します。値0はクライアントのキープアライブ処理を無効にします。

Last Will QoS Level

QoS 遺言メッセージを公開する際に使用するレベル。

Last Will Topic

クライアントのLast Willを送るトピック。

最大列サイズ

MQTT メッセージは、プロセッサの実行スケジュール頻度に関係なく、常にトピックの購読者に送信されます。「実行スケジュール」が、このプロセッサーに到着するメッセージのレートに比べて大幅に遅れている場合、このプロセッサーの内部キューにバックアップが発生する可能性があります。このプロパティは、このプロセッサが内部キューで一度にメモリに保持するメッセージの最大数を指定します。このデータは、 NiFi を再起動すると失われます。

サービス品質 (QoS)

メッセージを受信する Quality of Service (QoS)。値 '0'、'1'、'2' を受け付けます。'0' は「多くても1回」、'1' は「少なくとも1回」、'2' は「ちょうど1回」を表します。

セッション有効期限間隔

この間隔が過ぎると、ブローカーはクライアントを失効させ、セッション状態をクリアします。

トピックフィルター

MQTT トピックフィルターで、購読するトピックを指定します。

add-attributes-as-fields

このプロパティをtrueにセットすると、各記録にデフォルト・フィールドが追加されます：topic、_qos、_isDuplicate、_isRetained。

record-reader

受信した MQTT メッセージを記録にパースするために使用するRecord Reader。

メッセージ

MQTT メッセージ出力

record.count

受信した記録数

mqtt.topic

MQTT メッセージを受信したトピック

mqtt.isDuplicate

このメッセージがすでに受信したものと重複しているかどうか。