第 50 章 Kafka 源

bootstrapServers *

bootstrap 服务器

以逗号分隔的 Kafka Broker URL 列表

字符串

password *

密码

在 kafka 中验证的密码

字符串

topic *

主题名称

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

字符串

User *

用户名

为 Kafka 验证的用户名

字符串

allowManualCommit

允许手动提交

是否允许进行手动提交

布尔值

False

autoCommitEnable

自动提交启用

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

布尔值

True

autoOffsetReset

自动偏移重置

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

字符串

latest

consumerGroup

消费者组

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

字符串

my-group-id

deserializeHeaders

自动序列化标头

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

布尔值

True

pollOnError

轮询错误行为

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

字符串

ERROR_HANDLER

saslMechanism

SASL 机制

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

字符串

PLAIN

securityProtocol

安全协议

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

字符串

SASL_SSL

topicIsPattern

主题模式

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

布尔值

False