第34章 Kafka Source

Kafka トピックからデータを受信します。

34.1. 設定オプション

次の表は、kafka-source Kamelet で利用できる設定オプションをまとめたものです。

プロパティー名前説明デフォルト

Topic *

トピック名

Kafka トピック名のコンマ区切りリスト

string

  

bootstrapServers *

ブローカー

Kafka Broker URL のコンマ区切りリスト

string

  

securityProtocol

セキュリティープロトコル

ブローカーとの通信に使用されるプロトコル。SASL_PLAINTEXT、PLAINTEXT、SASL_SSL、および SSL がサポートされます。

string

"SASL_SSL"

 

saslMechanism

SASL メカニズム

使用される Simple Authentication and Security Layer(SASL) メカニズム。

string

"PLAIN"

 

user *

Username

Kafka に対して認証を行うためのユーザー名

string

  

Password *

Password

kafka に対して認証を行うためのパスワード

string

  

autoCommitEnable

自動コミットの有効化

true の場合、コンシューマーによってすでにフェッチされているメッセージのオフセットを ZooKeeper に定期的にコミットします。

boolean

true

 

allowManualCommit

手動コミットを許可する

手動コミットを許可するかどうか。

boolean

false

 

autoOffsetReset

自動オフセットリセット

初期オフセットがない場合のアクション。列挙は 3 つあり、値は latest、earliest、none のいずれかです。

string

"latest"

 

pollOnError

poll On エラー動作

新しいメッセージのポーリング中に、kafka が例外を出力した場合のアクション。5 つの列挙があり、値は DISCARD、ERROR_HANDLER、RECONNECT、RETRY、STOP のいずれかです。

string

"ERROR_HANDLER"

 

deserializeHeaders

ヘッダーを自動的に逆シリアル化

有効にすると、Kamelet ソースはすべてのメッセージヘッダーを文字列表現に逆シリアル化します。デフォルトは false です。

boolean

true

 
注記

アスタリスク (*) のマークが付いたフィールドは必須です。