第 44 章 Kafka Sink

将数据发送到 Kafka 主题。

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

这两个标头都是可选的。

44.1. 配置选项

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

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

注意

带有星号 packagemanifests 的字段是必需的。

返回顶部