Apache Kafka - メッセージ公開アクション（バッチ）
Publish messagesバッチアクションは、選択したKafkaトピックに複数のメッセージを1回のバッチ操作で公開します。 Kafkaメッセージ本文とメッセージキーに対して、AVRO形式またはProtobuf形式のスキーマを選択できます。
入力
| 入力フィールド | 説明 |
|---|---|
| トピック | メッセージを公開するトピックの名前を選択または入力します。 |
| メッセージスキーマソース | メッセージスキーマの定義場所を選択します。 オプションは次のとおりです:
|
| メッセージスキーマ | Message schema sourceの選択内容に基づいてメッセージスキーマを選択します。 |
| Protobufメッセージスキーマ | スキーマレジストリからProtobufメッセージスキーマを選択します。 このフィールドは、メッセージスキーマソースとしてCommon data model - Protobufが選択されている場合に表示されます。 |
| キースキーマタイプ | メッセージキーのスキーマタイプを設定します。 オプションは次のとおりです:
|
| キースキーマ | 使用可能なスキーマからキースキーマを選択します。 このフィールドは、キースキーマタイプとしてSchema registryが選択されている場合に表示されます。 |
| パーティション | 明示的に公開するトピックパーティション（インデックスは0から始まります）を指定します。 指定しない場合、Kafkaがパーティションを自動的に選択します。 |
| レコード | Kafkaトピックに公開するレコードのリストを指定します。 このセクションを展開して、レコードソースと個々のメッセージの詳細を設定します。 |
| レコードソースリスト（Records） | 公開するレコードを含むリストデータピルを指定します。 リスト内の各項目は、Kafkaに公開する1つのメッセージを表します。 リスト入力の詳細。 |
| レコードフィールド（Message） | 各レコードのメッセージ内容を指定します。 |
| キー（レコード） | 各メッセージと共に保存するメッセージキーを指定します。 |
| メッセージヘッダー（レコード） | 各メッセージと共にヘッダーとして保存するキーと値のペアのリストを指定します。 ヘッダーキーは重複できます。 |
出力
出力には、正常に公開されたメッセージと、バッチ公開中に発生した失敗に関する情報が含まれます。 ダウンストリームステップで出力を使用するには、関連するデータピルをマッピングします。
| 出力フィールド | 説明 |
|---|---|
| 成功 | 正常に公開された各メッセージの結果を含むリスト。 |
| インデックス（成功） | 元の入力バッチ内のメッセージのインデックス（0から開始）。 |
| キー（成功） | メッセージと共に公開されたメッセージキー。 |
| サイズ（成功） | 公開されたメッセージのサイズ。 |
| タイムスタンプ（成功） | 公開されたメッセージのタイムスタンプ。 |
| パーティション（成功） | メッセージが追加されたパーティションID。 |
| オフセット（成功） | Kafka内の一意のメッセージ識別子であるメッセージオフセット。 |
| 失敗 | 公開に失敗した各メッセージの詳細を含むリスト。 |
| インデックス（失敗） | 元の入力バッチ内の失敗したメッセージのインデックス（0から開始）。 |
| キー（失敗） | 失敗したメッセージのメッセージキー。 |
| エラー（失敗） | メッセージの公開に失敗した理由を説明するエラーメッセージ。 |
Last updated: