トピック内の新しいメッセージトリガー

このトリガーを使用して、Confluent Cloudのトピックに作成された新しいメッセージを監視します。このトリガーは、ポーリング間隔ごとに新しいメッセージをチェックし、Workatoは各メッセージを別々のジョブとして処理します。

入力フィールド

フィールド	説明
Trigger poll interval	新しいイベントをチェックする頻度を決定します。空白の場合、デフォルトは5分です。許可される最小値は5分です。
Topic	リストからトピックを選択するか、トピック名を入力します。
Message schema source	メッセージスキーマが定義されている場所を、共通データモデルまたはConfluent Cloudのスキーマレジストリから選択します。スキーマレジストリからスキーマを取得するには、Confluent Cloud接続をStream Governance API credentialsで構成する必要があります。
Message schema	共通データモデルまたはスキーマレジストリからメッセージスキーマを選択します。
Initial offset	初期オフセットを決定します。この値は、Kafkaに初期オフセットがない場合や、現在のオフセットがサーバーに存在しない場合に、Workatoが操作をどのように処理するかを示します。Earliest に設定すると、Workatoはトピック内の最も古い利用可能なメッセージから取得を開始します。Latest に設定すると、Workatoは最も最近のメッセージから取得を開始します。この値のデフォルトは Earliest です。

出力フィールド

出力データツリーには、メッセージに関する情報が含まれています。これには、キー、生のメッセージ、パーティション、オフセット、タイムスタンプ、サイズが含まれます。

フィールド	説明
Key	メッセージキー。この値はメッセージとともに保存されます。
Message	メッセージの内容。
Raw message	生のメッセージの内容。
Partition	パーティション番号。
Offset	オフセット番号。
Timestamp	メッセージのタイムスタンプ。
Size	メッセージのサイズ（バイト単位）。