第 34 章 Kafka Source

主题 *

主题名称

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

字符串

bootstrapServers *

代理（Broker）

Kafka Broker URL 的逗号分隔列表

字符串

securityProtocol

安全协议

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

字符串

"SASL_SSL"

saslMechanism

SASL 机制

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

字符串

"说明"

用户 *

用户名

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

字符串

密码 *

密码

用于对 kafka 进行身份验证的密码

字符串

autoCommitEnable

自动提交启用

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

布尔值

true

allowManualCommit

允许手动提交

是否允许手动提交

布尔值

false

autoOffsetReset

自动重置

没有初始偏移时要做什么。有 3 个枚举，值可以是最新的、最早的、无数个

字符串

"latest"

pollOnError

轮询 On Errorhavior

如果 kafka 异常在轮询新消息时要做什么。有 5 个枚举，值可以是 DISCARD、ERROR_HANDLER、RECONNECT、RETRY、STOP

字符串

"ERROR_HANDLER"

deserializeHeaders

自动对标头进行反序列化标头

启用 Kamelet 源后，将把所有消息标头序列化为 String representation。默认值为 false。

布尔值

true