Product Advantages¶

Data Production and Data Consumption Decoupling¶

Subscribed data will be stored in Kafka Topics. The stored data will be consumed only when the data consumption clients are started.

Data Flow Control¶

Applications will actively pull the subscribed data from Kafka Topics, achieving client-side data flow control.

Rich Data Filtering Conditions¶

Supporting multiple data filtering conditions to subscribe the measurement point data, alert data, and event data of specific organizations and assets.

Cross-organization Data Subscription¶

Supporting cross-organization data subscription through purchasing applications of other organizations.

Data Security and Completeness¶

Supporting at-least-once message delivery semantics to ensure that subscribed data is consumed at least once, thus avoiding data loss.

Running Status Monitoring¶

Monitoring the running statistics of data subscription jobs (producer rates, consumer rates, offset, and lag) to ensure that subscribed data is consumed in time without delay.

Data Consumption Groups¶

Supporting consumer groups. A topic can be consumed by multiple consumers (2 consumers are supported currently) in a same group at the same time, improving data consumption efficiency in case of huge data volume. A topic can also be consumed by multiple consumer groups.

Data Consumption at Breakpoints¶

Supporting the resuming of data consumption at breakpoint. Within 24 hours after the consumer client stops consuming data, the same consumer group can be used to continue consuming subscribed data from the breakpoint.