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