第 45 章 Kafka 源

Topic *

主题名称

以逗号分隔的 Kafka 主题名称列表

字符串

bootstrapServers *

代理（Broker）

以逗号分隔的 Kafka Broker URL 列表

字符串

securityProtocol

安全协议

用于与代理通信的协议。支持 SASL_PLAINTEXT, PLAINTEXT, SASL_SSL 和 SSL

字符串

"SASL_SSL"

saslMechanism

SASL 机制

使用简单身份验证和安全层(SASL)机制。

字符串

"PLAIN"

user *

用户名

为 Kafka 进行身份验证的用户名

字符串

密码 X

密码

为 kafka 进行身份验证的密码

字符串

autoCommitEnable

自动提交启用

如果为 true，请定期提交到 ZooKeeper，以偏移已由消费者获取的信息。

布尔值

true

allowManualCommit

允许手动提交

是否允许手动提交

布尔值

false

autoOffsetReset

自动偏移重置

没有初始偏移时该怎么办。有 3 个枚举，值可以是 latest, earliest, none 之一

字符串

"latest"

pollOnError

轮询错误行为

如果 kafka threw 异常轮询新消息，则该怎么办。有 5 enums，值可以是 DISCARD, ERROR_HANDLER, RECONNECT, RETRY, STOP 之一

字符串

"ERROR_HANDLER"

deserializeHeaders

自动序列化标头

启用 Kamelet 源会将所有消息标头反序列化为 String 表示。默认值为 false。

布尔值

true

consumerGroup

消费者组

唯一标识此源所属用户组的字符串

字符串

"my-group-id"