第 33 章 Kafka Sink
将数据发送到 Kafka 主题。
Kamelet 能够理解要设置以下标头：
-
密钥/ce-key: 作为消息键 -
partition-key/ce-partitionkey：作为消息分区密钥
标头都是可选的。
33.1. 配置选项
下表总结了可用于 kafka-sink Kamelet 的配置选项：
| 属性 | 名称 | 描述 | 类型 | 默认 | 示例 |
|---|---|---|---|---|---|
| bootstrapServers * | 代理（Broker） | Kafka Broker URL 的逗号分隔列表 | 字符串 | ||
| 密码 * | 密码 | 用于对 kafka 进行身份验证的密码 | 字符串 | ||
| 主题 * | 主题名称 | Kafka 主题名称的逗号分隔列表 | 字符串 | ||
| 用户 * | 用户名 | 向 Kafka 进行身份验证的用户名 | 字符串 | ||
| saslMechanism | SASL 机制 | 使用简单身份验证和安全层(SASL)机制。 | 字符串 |
| |
| securityProtocol | 安全协议 | 用于与代理通信的协议。支持 SASL_PLAINTEXT, PLAINTEXT, SASL_SSL 和 SSL | 字符串 |
|
带有星号(*)标记的字段为必填。
