Kafka Sub¶

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

节点类型¶

Input。

输入和输出能力¶

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

节点属性¶

名称

该节点的名称。

主机

主机地址或域名。

Topic

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

鉴权

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

匿名: 无需鉴权。
用户名/密码: 输入用于鉴权的 用户名 和密码。

描述

该节点的描述。

测试连接

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

使用限制¶

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

示例¶

输入示例¶

该节点不接收任何输入消息。

输出示例¶

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

{
    "MetaData":{
        "topic":"topic1",
        "topic":"topic2"
    },
    "Body":{
        "externalId":"externalId",
        "timestamp":24214324324,
        "measurepoints":{
            "speed":32,
            "heat":40
        }
    }
}