第45章 Kafka Source

topic *

Topic Names

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

string

bootstrapServers *

Brokers

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

string

securityProtocol

Security Protocol

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

string

"SASL_SSL"

saslMechanism

SASL Mechanism

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

string

"PLAIN"

user *

Username

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

string

password *

パスワード

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

string

autoCommitEnable

Auto Commit Enable

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

boolean

true

allowManualCommit

Allow Manual Commit

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

boolean

false

autoOffsetReset

Auto Offset Reset

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

string

"latest"

pollOnError

Poll On Error Behavior

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

string

"ERROR_HANDLER"

deserializeHeaders

Automatically Deserialize Headers

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

boolean

true

consumerGroup

Consumer Group

このソースが属するコンシューマーのグループを一意に識別する文字列

string

"my-group-id"