第 34 章 Kafka Source
从 Kafka 主题接收数据。
34.1. 配置选项
下表总结了 kafka-source Kamelet 的配置选项：
| 属性 | 名称 | 描述 | 类型 | 默认 | 示例 |
|---|---|---|---|---|---|
| 主题 * | 主题名称 | Kafka 主题名称的逗号分隔列表 | 字符串 | ||
| bootstrapServers * | 代理（Broker） | Kafka Broker URL 的逗号分隔列表 | 字符串 | ||
| securityProtocol | 安全协议 | 用于与代理通信的协议。支持 SASL_PLAINTEXT, PLAINTEXT, SASL_SSL 和 SSL | 字符串 |
| |
| saslMechanism | SASL 机制 | 使用简单身份验证和安全层(SASL)机制。 | 字符串 |
| |
| 用户 * | 用户名 | 向 Kafka 进行身份验证的用户名 | 字符串 | ||
| 密码 * | 密码 | 用于对 kafka 进行身份验证的密码 | 字符串 | ||
| autoCommitEnable | 自动提交启用 | 如果为 true，请定期提交到由消费者获取的消息偏移。 | 布尔值 |
| |
| allowManualCommit | 允许手动提交 | 是否允许手动提交 | 布尔值 |
| |
| autoOffsetReset | 自动重置 | 没有初始偏移时要做什么。有 3 个枚举，值可以是最新的、最早的、无数个 | 字符串 |
| |
| pollOnError | 轮询 On Errorhavior | 如果 kafka 异常在轮询新消息时要做什么。有 5 个枚举，值可以是 DISCARD、ERROR_HANDLER、RECONNECT、RETRY、STOP | 字符串 |
| |
| deserializeHeaders | 自动对标头进行反序列化标头 |
启用 Kamelet 源后，将把所有消息标头序列化为 String representation。默认值为 | 布尔值 |
|
带有星号(*)标记的字段为必填。
