第32章 Kafka Source
Kafka トピックからデータを受信します。
32.1. 設定オプション
次の表は、kafka-source Kameletで利用できる設定オプションをまとめたものです。
| プロパティー | 名前 | 詳細 | タイプ | デフォルト | 例 |
|---|---|---|---|---|---|
| Topic * | トピック名 | Kafka トピック名のコンマ区切りリスト | 文字列 | ||
| bootstrapServers * | ブローカー | Kafka Broker URL のコンマ区切りリスト | 文字列 | ||
| securityProtocol | セキュリティープロトコル | ブローカーとの通信に使用されるプロトコル。SASL_PLAINTEXT、PLAINTEXT、SASL_SSL、および SSL がサポートされます。 | 文字列 |
| |
| saslMechanism | SASL メカニズム | 使用される Simple Authentication and Security Layer(SASL)メカニズム。 | 文字列 |
| |
| user * | Username | Kafka に対して認証を行うためのユーザー名 | 文字列 | ||
| Password * | Password | kafka に対して認証を行うためのパスワード | 文字列 | ||
| autoCommitEnable | 自動コミットの有効化 | true の場合、コンシューマーによってすでにフェッチされたメッセージのオフセットを ZooKeeper に定期的にコミットします。 | boolean |
| |
| allowManualCommit | 手動コミットを許可する | 手動コミットを許可するかどうか。 | boolean |
| |
| autoOffsetReset | 自動オフセットリセット | 初期オフセットがない場合のアクション。列挙は 3 つあり、値は latest、earliest、none のいずれかです。 | 文字列 |
| |
| pollOnError | poll On エラー動作 | 新しいメッセージのポーリング中に、kafka が例外をスローした場合のアクション。5 つの列挙があり、値は DISCARD、ERROR_HANDLER、RECONNECT、RETRY、STOP のいずれかです。 | 文字列 |
| |
| deserializeHeaders | ヘッダーの自動デシリアライズ |
Kamelet ソースを有効にすると、すべてのメッセージヘッダーが String 表現にデシリアライズされます。デフォルトは | boolean |
|
アスタリスク(*)のマークが付いたフィールドは必須です。
