Apache Kafka - Publish messageアクション
Publish messageアクションは、選択したKafkaトピックに新しいメッセージを公開します。 Kafkaメッセージ本文とメッセージキーに対して、AVRO形式またはProtobuf形式のスキーマを選択できます。
1回のバッチ操作で複数のメッセージを公開するには、Publish messagesアクション（バッチ）を使用します。
メッセージサイズの制限
最大メッセージサイズは50 MBです。
入力
| 入力フィールド | 説明 |
|---|---|
| トピック | メッセージの公開先トピックの名前を選択または入力します。 |
| メッセージスキーマソース | メッセージスキーマソースを定義します。 オプションは次のとおりです:
|
| メッセージスキーマ | Message schema sourceの選択内容に基づいてメッセージスキーマを選択します。 |
| Protobufメッセージスキーマ | スキーマレジストリからProtobufメッセージスキーマを選択します。 このフィールドは、メッセージスキーマソースとしてCommon data model - Protobufが選択されている場合に表示されます。 |
| キースキーマタイプ | メッセージキーのスキーマタイプを設定します。 オプションは次のとおりです:
|
| キースキーマ | 使用可能なスキーマからキースキーマを選択します。 このフィールドは、キースキーマタイプとしてSchema registryが選択されている場合に表示されます。 |
| パーティション | 明示的に公開するトピックパーティション（インデックスは0から始まります）を指定します。 指定しない場合、Kafkaがパーティションを自動的に選択します。 |
| メッセージ | メッセージ内容を指定します。 |
| キー | メッセージとともに保存するメッセージキーを指定します。 |
| メッセージヘッダー | ヘッダーとしてメッセージとともに保存するキーと値のペアのリストを指定します。 ヘッダーキーは重複できます。 |
| キー（メッセージヘッダー） | ヘッダーキー名を入力します。 |
| 値（メッセージヘッダー） | ヘッダー値を入力します。 |
出力
出力には、アクションが成功した後の有用な情報が含まれます。 ダウンストリームステップで出力を使用するには、関連するデータピルをマッピングします。
| 出力フィールド | 説明 |
|---|---|
| サイズ | 公開されたメッセージのサイズ。 |
| タイムスタンプ | 公開されたメッセージのタイムスタンプ。 |
| パーティション | メッセージが追加されたパーティションID。 |
| オフセット | Kafka内の一意のメッセージ識別子であるメッセージオフセット。 |
Last updated: