42. Kafka Sink
将数据发送到 Kafka 主题。
Kamelet 可以了解要设置的以下标头:
-
Key
/ce-key
: 作为消息键 -
partition-key
/ce-partitionkey
: 作为消息分区键
这两个标头都是可选的。
42.1. 配置选项 复制链接链接已复制到粘贴板!
下表总结了 kafka-sink
Kamelet 可用的选项:
属性 | 名称 | 描述 | 类型 | 默认 | 示例 |
---|---|---|---|---|---|
bootstrapServers * | 代理(Broker) | 以逗号分隔的 Kafka Broker URL 列表 |
| ||
topic * | 主题名称 | 以逗号分隔的 Kafka 主题名称列表 |
| ||
User * | 用户名 | 为 Kafka 验证的用户名 |
| ||
password | 密码 | 在 kafka 中验证的密码 |
| ||
saslMechanism | SASL 机制 | 使用简单身份验证和安全层(SASL)机制。 | 字符串 |
| |
securityProtocol | 安全协议 | 用于与代理通信的协议。支持 SASL_PLAINTEXT、PLAINTEXT、SASL_SSL 和 SSL | 字符串 |
|
* = 标记为星号的字段 是必需的。
42.2. 依赖项 复制链接链接已复制到粘贴板!
在运行时,'kafka-sink Kamelet 依赖于以下依赖项:
- camel:kafka
- camel:kamelet
- camel:core
42.3. kamelets 源文件 复制链接链接已复制到粘贴板!
https://github.com/apache/camel-kamelets/blob/4.8.x/kamelets/kafka-sink.kamelet.yaml