GetAzureEventHub 2025.5.31.15

バンドル

org.apache.nifi | nifi-azure-nar

説明

信頼性の高いチェックポイント追跡なしでMicrosoft Azureイベントハブからのメッセージを受信します。クラスタ環境では、 GetAzureEventHub プロセッサー インスタンスは独立して動作し、すべてのクラスタノードがすべてのメッセージを処理します(プロセッサーをプライマリのみモードで実行している場合を除く)。ConsumeAzureEventHub は、Azure Event Hubs からのメッセージを受信するための推奨アプローチを提供します。このプロセッサーは、Azure イベントハブへの接続用のスレッドプールを作成します。

タグ

Azure、クラウド、eventhub、イベント、マイクロソフト、ストリーミング、ストリーム

入力要件

FORBIDDEN

機密動的プロパティをサポート

false

プロパティ

プロパティ

説明

イベントハブ コンシューマーグループ

イベントをプルする際に使用するコンシューマーグループの名前。

イベントハブメッセージのエンキュー時間

YYYY-MM-DDThhmmss.sssZ (2016-01-01T01:01:01.000Z) という形式でフォーマットされた、以下から読み込みを開始するイベントハブにエンキューされているべきメッセージからのタイムスタンプ (ISO-8601 Instant) です。

イベントハブ名

Azure イベントハブのソース名

イベントハブ名前空間

サービス バス エンドポイント ドメインのプレフィックスが付いた Azure イベントハブの名前空間

パーティション・レシーバー・タイムアウト (ミリ秒)

パーティション・レシーバーがフェッチ・サイズを受信してから戻るまでの時間(ミリ秒単位)。デフォルトは60000です。

パーティション・レシーバーのフェッチ・サイズ

レシーバーがリターンする前にイベント・ハブ・パーティションからフェッチすべきイベントの数。デフォルトは100です。

サービス バス エンドポイント

デフォルトのwindows.netドメイン以外の名前空間をサポートするため。

共有アクセスポリシー名

共有アクセスポリシーの名前。このポリシーは、保険金請求に耳を傾ける必要があります。

共有アクセスポリシー プライマリキー

共有アクセスポリシーのキー。プライマリ・キーとセカンダリ・キーのどちらを使ってもかまいません。

輸送タイプ

Azureイベントハブとの通信に使用される高度なメッセージキューイングプロトコルのトランスポートタイプ

proxy-configuration-service

ネットワークリクエストをプロキシするプロキシ構成Controller Serviceを指定します。

use-managed-identity

Azure VM/VMSS の管理 ID を使用するかどうかを選択します。

リレーションシップ

名前

説明

success

イベントハブから正常に受信された FlowFile は、この Relationship に転送されます。

属性の書き込み

名前

説明

eventhub.enqueued.timestamp

メッセージがイベントハブにエンキューされた時間(エポックからのミリ秒、 UTC)。

eventhub.offset

メッセージが格納されたパーティション内のオフセット

eventhub.sequence

メッセージに関連するAzureシーケンス番号

eventhub.name

メッセージが取り出されたイベントハブの名前。

eventhub.partition

メッセージが取り出されたイベントハブ・パーティションの名前。

eventhub.property.*

このメッセージのアプリケーション・プロパティ。IE: 'アプリケーション'は'eventhub.property.application'となります。

こちらもご覧ください