Apache Kafka - メッセージの公開アクション

メッセージの公開

このアクションは、選択したKafkaトピックに新しいメッセージを公開します。Kafkaメッセージの本文とメッセージキーのスキーマをAVRO形式で選択できます。

メッセージの公開アクション

入力フィールド

入力フィールド	説明
トピック	新しいメッセージを公開するトピックを選択します。トピックがロードされると、データを入力することができます。
メッセージスキーマのソース	メッセージスキーマのソースを定義します。 Common data model が選択されている場合、Workatoで定義されたスキーマが使用されます。 Schema registry (on-prem) オプションを選択すると、Kafkaクラスターで定義されたスキーマを使用できます。このオプションでは、schema.registry.url プロパティの設定が必要です。WorkatoはAVRO形式のスキーマをサポートしています。
メッセージスキーマ	メッセージスキーマの形式を、メッセージスキーマのソース入力に基づいて選択します。
キースキーマのタイプ	メッセージスキーマのソースと同様に、メッセージキーのスキーマタイプを設定できます。 Defined in schema registry (on-prem) オプションでは、schema.registry.url プロパティの設定が必要です。WorkatoはAVRO形式のスキーマをサポートしています。

出力フィールド

成功したアクションの後、出力には有用な情報が含まれています。出力を下流のステップで使用するには、関連するデータピルにマッピングします。

メッセージの公開出力フィールド

フィールド名	説明
サイズ	挿入されたメッセージのサイズです。
タイムスタンプ	挿入されたメッセージのタイムスタンプです。
パーティション	メッセージが追加されたトピックのパーティションのIDです。
オフセット	Kafka内の一意のメッセージ識別子であるメッセージオフセットです。