Confluent Cloud - topicの新規メッセージトリガー
このトリガーを使用して、Confluent Cloud topicで作成された新規メッセージをリッスンします。このトリガーはpoll intervalごとに新規メッセージを確認し、Workatoは各メッセージを個別のジョブとして処理します。
入力
| フィールド | 説明 |
|---|---|
| トリガーポーリング間隔 | 新規イベントをチェックする頻度を決定します。空白のままにすると、デフォルトで5分になります。許可される最小値は5分です。 |
| トピック | リストからトピックを選択するか、トピック名を入力します。 |
| メッセージスキーマソース | メッセージスキーマがCommon data modelまたはConfluent Cloudのスキーマレジストリのどちらで定義されているかを選択します。スキーマレジストリからスキーマを取得するには、Stream Governance API認証情報を使用してConfluent Cloudコネクションを設定する必要があります。 |
| メッセージスキーマ | Common data modelまたはスキーマレジストリからメッセージスキーマを選択します。 |
| 初期オフセット | 初期オフセットを決定します。この値は、Kafkaに初期オフセットがない場合、または現在のオフセットがサーバーに存在しなくなった場合に、Workatoが操作をどのように処理するかを指定します。 Earliestに設定すると、Workatoはトピック内で利用可能な最も古いメッセージからメッセージの取得を開始します。 Latestに設定すると、Workatoは最新のメッセージからメッセージの取得を開始します。この値のデフォルトはEarliestです。 |
出力
出力datatreeには、メッセージに関する情報が含まれます。これには、キー、未加工メッセージ、パーティション、オフセット、タイムスタンプ、およびサイズが含まれます。
| フィールド | 説明 |
|---|---|
| キー | メッセージキー。この値はメッセージとともに保存されます。 |
| メッセージ | メッセージコンテンツ。 |
| Raw message | 未加工のメッセージコンテンツ。 |
| パーティション | パーティション番号。 |
| オフセット | オフセット番号。 |
| タイムスタンプ | メッセージのタイムスタンプ。 |
| サイズ | メッセージのサイズ（バイト単位）。 |
最終更新日: