第 33 章 Kafka Sink

将数据发送到 Kafka 主题。

Kamelet 可以理解以下要设置的标头：

密钥 / ce-key: 作为消息键
partition-key / ce-partitionkey: 作为消息分区密钥

两个标头都是可选的。

33.1. 配置选项

下表总结了 kafka-sink Kamelet 的配置选项：

属性	名称	描述	类型	默认	Example
bootstrapServers *	代理（Broker）	Kafka Broker URL 的逗号分隔列表	字符串
密码 *	密码	对 kafka 进行身份验证的密码	字符串
主题 *	主题名称	Kafka 主题名称的逗号分隔列表	字符串
用户 *	用户名	在 Kafka 中进行身份验证的用户名	字符串
saslMechanism	SASL Mechanism	使用简单验证和安全层(SASL)机制。	字符串	`"PLAIN"`
securityProtocol	安全协议	用于与代理通信的协议。SASL_PLAINTEXT, PLAINTEXT, SASL_SSL 和 SSL 受到支持	字符串	`"SASL_SSL"`

注意

带星号(*)标记的字段是必需的。

返回顶部

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情，请参阅红帽博客.

關於紅帽

我们提供强化的解决方案，使企业能够更轻松地跨平台和环境（从核心数据中心到网络边缘）工作。

Theme

© 2025 Red Hat, Inc.