Red Hat Camel K is no longer supported.
As of June 30, 2025, Red Hat build of Camel K has reached End of Life. The suggested replacements is Red Hat build of Apache Camel. For details about moving, see the Camel K to Camel Quarkus migration guide.第 43 章 Kafka Sink
将数据发送到 Kafka 主题。
Kamelet 可以理解以下要设置的标头:
-
密钥
/ce-key
: 作为消息键 -
partition-key
/ce-partitionkey
: 作为消息分区密钥
两个标头都是可选的。
43.1. 配置选项 复制链接链接已复制到粘贴板!
下表总结了 kafka-sink
Kamelet 的配置选项:
属性 | Name | 描述 | 类型 | 默认 | Example |
---|---|---|---|---|---|
bootstrapServers * | 代理(Broker) | Kafka Broker URL 的逗号分隔列表 | 字符串 | ||
密码 * | 密码 | 对 kafka 进行身份验证的密码 | 字符串 | ||
主题 * | 主题名称 | Kafka 主题名称的逗号分隔列表 | 字符串 | ||
用户 * | 用户名 | 在 Kafka 中进行身份验证的用户名 | 字符串 | ||
saslMechanism | SASL Mechanism | 使用简单验证和安全层(SASL)机制。 | 字符串 |
| |
securityProtocol | 安全协议 | 用于与代理通信的协议。SASL_PLAINTEXT, PLAINTEXT, SASL_SSL 和 SSL 受到支持 | 字符串 |
|
带星号(*)标记的字段是必需的。