x/kafkaProducer组件：发布kafka数据。用于把当前消息负荷发送到kafka指定主题。

配置

该组件允许通关过server字段复用共享的kafka连接客户端。参考组件连接复用 。

字段	类型	是否必填	说明	默认值
topic	string	是	发布主题，可以使用组件配置变量	-
key	string	否	分区键，可以使用组件配置变量	-
partition	int	否	分区编号	-
brokers	[]string	是	kafka服务器地址列表	["localhost:9092"]

Relation Type

• Success: 执行成功，把消息发送到Success链
• Failure: 执行失败，把消息发送到Failure链

执行结果

• 执行成功：
  • msg.data：保持不变。
  • msg.Metadata.partition：分区编号。
  • msg.Metadata.offset：偏移量。

配置示例

{
  "id": "s5",
  "type": "x/kafkaProducer",
  "name": "发布到kafka",
  "debugMode": true,
  "configuration": {
    "topic": "device.msg.request",
    "brokers": ["localhost:9092"]
  }
}

应用示例

应用示例参考：kafka_producer_test (opens new window)