第 44 章 Kafka 源
从 Kafka 主题接收数据。
44.1. 配置选项
下表总结了 kafka-source Kamelet 的配置选项：
| 属性 | 名称 | 描述 | 类型 | 默认 | Example |
|---|---|---|---|---|---|
| 主题 * | 主题名称 | Kafka 主题名称的逗号分隔列表 | 字符串 | ||
| bootstrapServers * | 代理（Broker） | Kafka Broker URL 的逗号分隔列表 | 字符串 | ||
| securityProtocol | 安全协议 | 用于与代理通信的协议。SASL_PLAINTEXT, PLAINTEXT, SASL_SSL 和 SSL 受到支持 | 字符串 |
| |
| saslMechanism | SASL Mechanism | 使用简单验证和安全层(SASL)机制。 | 字符串 |
| |
| 用户 * | 用户名 | 在 Kafka 中进行身份验证的用户名 | 字符串 | ||
| 密码 * | 密码 | 对 kafka 进行身份验证的密码 | 字符串 | ||
| autoCommitEnable | 自动提交启用 | 如果为 true，请定期提交 ZooKeeper 被消费者获取的消息偏移。 | 布尔值 |
| |
| allowManualCommit | 允许手动提交 | 是否允许手动提交 | 布尔值 |
| |
| autoOffsetReset | Auto Offset Reset | 当没有初始偏移时怎么办。共有 3 个 enums，值可以是最新的、最早、无 | 字符串 |
| |
| pollOnError | 轮询错误行为 | 如果 kafka threw 在轮询新消息时出现异常，该怎么办。共有 5 个枚举值，值可以是 DISCARD、ERROR_HANDLER、RECONNECT、RETRY、STOP 之一 | 字符串 |
| |
| deserializeHeaders | 自动销毁标头 |
启用 Kamelet 源会将所有消息标头反序列化为字符串表示。默认值为 | 布尔值 |
|
带星号(*)标记的字段是必需的。
