产品优势¶
数据生产与消费解耦¶
被订阅的数据会保存在 Kafka Topic 中，当数据消费客户端启动后才开始消费数据。
客户端流控¶
应用消费数据时，采用主动拉取的模式，实现了应用客户端的流量控制。
丰富的数据过滤条件¶
支持多种数据过滤条件，可订阅指定客户、指定设备的测点数据、告警数据、和事件数据。
跨组织订阅¶
通过应用授权（购买应用），支持订阅多个组织的资产数据。
数据完整性¶
保证 at-least-once 语义，确保订阅数据至少被消费一次，不会造成数据丢失。
运行监控¶
支持查看和监控订阅任务的运行情况，对比产生订阅数据的速率和消费订阅数据的速率，查看是否有消费数据延迟，确保订阅数据被及时消费。
集群消费数据¶
支持集群消费数据，即同一个 Topic 可以被同一个 Consumer Group 内的多个 Consumer Client 均摊消费（目前支持2个 Consumer Client），也可以被多个 Consumer Group 重复消费。
断点续传¶
支持断点续传，即 Consumer Client 停止消费数据后的24小时内，可使用相同的 Consumer Group 在断点处继续消费订阅的数据。订阅的数据在 Kafka Topic 中的存储时常默认为三天，所以订阅任务停止3天内，可以在上一次的消费位置继续消费订阅数据。