第 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

字符串

"SASL_SSL"

 
注意

带有星号(*)标记的字段为必填。