第 45 章 Kafka 源
从 Kafka 主题接收数据。
45.1. 配置选项
下表总结了 kafka-source Kamelet 可用的配置选项：
| 属性 | 名称 | 描述 | 类型 | 默认 | 示例 |
|---|---|---|---|---|---|
| topic 114 | 主题名称 | Kafka 主题名称的逗号分隔列表 | 字符串 | ||
| bootstrapServers * | 代理（Broker） | Kafka Broker URL 的逗号分隔列表 | 字符串 | ||
| securityProtocol | 安全协议 | 用于与代理通信的协议。支持 SASL_PLAINTEXT, PLAINTEXT, SASL_SSL 和 SSL | 字符串 |
| |
| saslMechanism | SASL 机制 | 使用简单验证和安全层(SASL)机制。 | 字符串 |
| |
| 用户 站 | 用户名 | 要向 Kafka 进行身份验证的用户名 | 字符串 | ||
| password 114 | 密码 | 向 kafka 进行身份验证的密码 | 字符串 | ||
| autoCommitEnable | auto Commit Enable | 如果为 true，请定期提交到 ZooKeeper，以偏移已由消费者获取的信息。 | 布尔值 |
| |
| allowManualCommit | 允许手动提交 | 是否允许手动提交 | 布尔值 |
| |
| autoOffsetReset | 自动偏移重置 | 在没有初始偏移时，要做什么。有 3 个 enums，值可以是 latest, earliest, none 之一 | 字符串 |
| |
| pollOnError | 轮询错误行为 | 如果 kafka 在轮询新消息时异常，则该怎么办。有 5 个枚举，值可以是 DISCARD、ERROR_HANDLER、RECONNECT、RETRY、STOP 之一 | 字符串 |
| |
| deserializeHeaders | 自动反序列化标头 |
当启用 Kamelet 源时，所有消息标头将反序列化为 String 表示。默认值为 | 布尔值 |
| |
| consumerGroup | 消费者组 | 唯一标识此源所属的消费者组的字符串 | 字符串 | "my-group-id" |
标记为星号的字段是必需的。
