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