43. Kafka 源

topic *

主题名称

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

字符串

bootstrapServers *

代理（Broker）

以逗号分隔的 Kafka Broker URL 列表

string

User *

用户名

为 Kafka 验证的用户名

string

password *

密码

在 kafka 中验证的密码

string

securityProtocol

安全协议

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

字符串

"SASL_SSL"

saslMechanism

SASL 机制

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

字符串

"PLAIN"

autoCommitEnable

自动提交启用

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

布尔值

true

allowManualCommit

允许手动提交

是否允许进行手动提交

布尔值

false

autoOffsetReset

自动偏移重置

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

字符串

"latest"

pollOnError

轮询错误行为

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

字符串

"ERROR_HANDLER"

deserializeHeaders

自动序列化标头

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

布尔值

true

consumerGroup

消费者组

唯一标识此源所属消费者组的字符串

字符串

"my-group-id"

topicIsPattern

主题模式

主题是否为模式（正则表达式）。这可用于订阅与模式匹配的主题数量。

布尔值

false