Kafka Pub


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

节点类型

External。

输入和输出能力

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

节点属性

../../_images/kafka_pub.png


名称

该节点的名称。


Host

主机地址或域名。


Topic

待发布至 Kafka 的信息主题。


鉴权

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

  • 匿名: 无需鉴权。

  • 用户名/密码: 输入用于鉴权的 用户名 和 密码。


描述

该节点的描述。

使用限制

  • 最多 topic 数：1

  • 由于 Kafka 并非 EnOS 管理，EnOS 不保证每次连接都能成功，连接问题可能是由于服务器停机或其他 EnOS 无法控制的因数造成。

示例

输入示例

JSON 对象作为输入的示例：

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

输出示例

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