第34章 Kafka Source

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