第 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  |   字符串  |   
								  | 
带有星号(*)标记的字段为必填。