第33章 Kafka Sink
データを Kafka トピックに送信します。
Kamelet は、設定するヘッダーについて理解することができます。
-
key/ce-key: メッセージキーとして -
partition-key/ce-partitionkey: メッセージパーティションキーとして
ヘッダーはいずれもオプションです。
33.1. 設定オプション
次の表は、kafka-sink Kamelet で利用できる設定オプションをまとめたものです。
| プロパティー | Name | 説明 | タイプ | デフォルト | 例 |
|---|---|---|---|---|---|
| bootstrapServers * | ブローカー | Kafka Broker URL のコンマ区切りリスト | string | ||
| Password * | 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 |
|
アスタリスク (*) のマークが付いたフィールドは必須です。
