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,将来自同一设备的消息发送至同一个分区。
描述
该节点的描述。
使用限制¶
最大 topic 数:1
最大并发数:8
由于 Kafka 并非 EnOS 管理,EnOS 不保证每次连接都能成功,连接问题可能是由于服务器停机或其他 EnOS 无法控制的因素造成。
示例¶
输入示例¶
JSON 对象作为输入的示例:
{
"externalId":"externalId",
"timestamp":24214324324,
"measurepoints":{
"speed":32,
"heat":40
}
}
输出示例¶
{
"externalId":"externalId",
"timestamp":24214324324,
"measurepoints":{
"speed":32,
"heat":40
}
}