第31章 Kafka Sink
データを Kafka トピックに送信します。
Kamelet は、設定するヘッダーについて理解することができます。
-
key/ce-key: メッセージキーとして -
partition-key/ce-partitionkey: メッセージパーティションキーとして
ヘッダーはいずれもオプションです。
31.1. 設定オプション
次の表は、kafka-sink Kameletで利用できる設定オプションをまとめたものです。
| プロパティー | Name (名前) | 詳細 | 型 | デフォルト | 例 |
|---|---|---|---|---|---|
| bootstrapServers * | ブローカー | Kafka Broker URL のコンマ区切りリスト | string | ||
| Password * | パスワード | kafka に対して認証を行うためのパスワード | string | ||
| Topic * | トピック名 | Kafka トピック名のコンマ区切りリスト | string | ||
| user * | ユーザ名 | Kafka に対して認証を行うためのユーザー名 | string | ||
| saslMechanism | SASL メカニズム | 使用される Simple Authentication and Security Layer(SASL)メカニズム。 | string |
| |
| securityProtocol | セキュリティープロトコル | ブローカーとの通信に使用されるプロトコル。SASL_PLAINTEXT、PLAINTEXT、SASL_SSL、および SSL がサポートされます。 | string |
|
アスタリスク(*)のマークが付いたフィールドは必須です。
