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内の一意のメッセージ識別子であるメッセージオフセットです。 |
Last updated: