Kafka Pub¶

Kafka Pub 节点用于建立一个 Kafka 客户端，将信息推送到第三方 Kafka 服务器。

节点类型¶

External。

该节点具有 1 个入口点和 1 个出口点。输入和输出可以是任何格式。输入 msg 是待发布的消息。

名称

该节点的名称。

Host

主机地址或域名。

Topic

待发布至 Kafka 的消息主题。

鉴权

鉴权方式，匿名或 用户名/密码。

Topic

待发布至 Kafka 的消息主题。

分区键

分区是 Kafka 中存储记录（record）的最小单位，分区键用于将消息发送至 Kafka 服务器中指定的分区。一个 Topic 可以有多个分区，带有相同分区键的消息将发送至同一分区，可以保证消息顺序。分区键为空的消息将随机发送至其中一个分区，可能打乱消息顺序。

你可以自定义分区键的内容。例如，为所有消息填入同一个分区键，消息将全部发送至同一个分区，其他分区不处理消息。又如，为来自不同设备的消息填入不同的 AssetId 或 ProductKey，可将来自同一设备的消息发送至同一分区。

支持表达式。例如，填入 ${msg.assetId}，将根据 msg 中的 AssetId，将来自同一设备的消息发送至同一个分区。

描述

该节点的描述。

JSON 对象作为输入的示例：

{
   "externalId":"externalId",
   "timestamp":24214324324,
   "measurepoints":{
     "speed":32,
     "heat":40
   }
 }

{
   "externalId":"externalId",
   "timestamp":24214324324,
   "measurepoints":{
     "speed":32,
     "heat":40
   }
 }