Confluent Cloud - メッセージの公開アクション
このアクションは、指定したConfluent Cloudトピックにメッセージを公開します。
入力
| フィールド | 説明 |
|---|---|
| トピック | リストからトピックを選択するか、トピック名を入力します。 |
| メッセージスキーマソース | メッセージスキーマがCommon data modelまたはConfluent Cloudのスキーマレジストリのどちらで定義されているかを選択します。 スキーマレジストリからスキーマを取得するには、Stream Governance API認証情報を使用してConfluent Cloudコネクションを設定する必要があります。 |
| メッセージスキーマ | Common data modelまたはスキーマレジストリからメッセージスキーマを選択します。 |
| メッセージ | 公開する予定のメッセージを入力します。 利用可能なフィールドは、選択したメッセージスキーマによって異なります。 |
| キー | メッセージキーを入力します。 この値はメッセージとともに保存されます。 パーティションが明示的に割り当てられていない場合、Kafkaはキーを使用して適切なトピックパーティションを選択します。 文字列キーのみがサポートされています。 |
| パーティション | メッセージのパーティションを決定します。 特定のトピックパーティションにメッセージを明示的に公開できます。 インデックスは0から始まります。 それ以外の場合、Kafkaがパーティションを自動的に選択します。 |
出力
| フィールド | 説明 |
|---|---|
| キー | メッセージのキー。 |
| メッセージ | メッセージコンテンツ。 |
| Raw message | 未加工のメッセージコンテンツ。 |
| パーティション | メッセージが公開されたパーティション。 |
| オフセット | パーティション内のメッセージのオフセット。 |
| タイムスタンプ | メッセージが作成されたときのタイムスタンプ。 |
| サイズ | メッセージのサイズ（バイト単位）。 |
Last updated: