43. Kafka Source

topic *

Topic Names

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

string

bootstrapServers *

Brokers

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

string

user *

Username

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

string

password *

Password

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

string

securityProtocol

Security Protocol

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

string

"SASL_SSL"

saslMechanism

SASL Mechanism

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

string

"PLAIN"

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"

topicIsPattern

Topic Is Pattern

トピックがパターン (正規表現) であるかどうか。これを使用して、パターンに一致する動的な数のトピックをサブスクライブできます。

boolean

false