CPC G06F 16/278 (2019.01) [G06F 16/2365 (2019.01); G06F 16/24568 (2019.01)] | 20 Claims |
1. A system comprising:
a processing device; and
a memory coupled to the processing device and storing instructions that, when executed by the processing device, cause the system to perform operations comprising:
generating a first shard comprising one or more messages;
associating the first shard with a first state attribute;
providing the first shard and the first state attribute as an atomic update within a data stream;
requesting the first state attribute from the first shard, wherein the first state attribute comprises a token that reflects a processing capacity of a streaming system;
receiving the first state attribute;
providing a second shard within the data stream based on the received first state attribute; and
adjusting an operation of a message production source of at least one of the one or more messages within the streaming system based on the received token that reflects the processing capacity of the streaming system.
|