Kafka Sub


Kafka Sub 建立一个 Kafka 客户端，该客户端最多可订阅 5 个 Kafka topics。

节点类型

Trigger。

输入和输出能力

该节点没有入口点，具有 1 个出口点。输出为客户端从所订阅的 topic 检索到的消息，可以是任何格式。Kafka topic 将自动保存到输出 metadata ${metadata.topic}。

节点属性

../../_images/kafka_sub.png


名称

必填。

该节点的名称。


Host

必填。

主机地址或域名。


Topic

必填。

订阅的 Kafka topic。最多可订阅 5 个 topics。


用户名

必填。

用于鉴权的用户名。


密码

必填。

用于鉴权的 用户名 对应的密码。


描述

选填。

该节点的描述。


测试连接

你可以点击 测试连接 按钮来测试 Kafka 连接。

使用限制

  • 连接数：1

  • 最大 topic 数：5

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

示例

输入示例

该节点节点没有入口点。

输出示例

从 Kafka topic 检索到的 JSON 对象响应示例。其 topic 信息存储在 metadata 中。

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