Method, system and apparatus for dynamically allocating event data

A system comprising:

• a plurality of client devices generating event data;
• a plurality of event processors, each event processor configured to process the event data from an allocated one or more of the plurality of client devices, the plurality of event processors including a first one of the event processors and a second one of the event processors, the first event processor configured to:
• receive a reallocation initiation message from a reallocated one of the plurality of client devices;
• and
• when no event data from the reallocated client device remains to be processed at the first event processor, send a reallocation completion message to a second event processor;
• and
• a partitioning controller including (i) a communications interface, (ii) a memory storing an initial shard map allocating initial subsets of the plurality of client devices to respective data stores, each data store associated with a respective one of the plurality of event processors, and (iii) a processor connected with the communications interface and the memory, the processor configured to:
• obtain an operational parameter for each of the plurality of event processors;
• generate an updated shard map based on the operational parameter for each of the plurality of event processors, the updated map allocating updated subsets of the plurality of client devices to the respective data stores;
• and
• responsive to generating the updated shard map, transmit a map update notification for the plurality of client devices via the communications interface.