# トピック内の新しいメッセージトリガー
このトリガーを使用して、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 | メッセージのサイズ(バイト単位)。 |
Last updated: 2025/1/28 7:29:31