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