CPC G06F 9/542 (2013.01) [G06F 9/544 (2013.01); G06F 9/546 (2013.01); G06F 16/182 (2019.01); G06F 16/244 (2019.01); G06F 16/2456 (2019.01); G06F 16/24568 (2019.01)] | 20 Claims |
1. A system comprising:
a stream processor configured to process events emitted by an event stream and output processed events;
a queue configured to receive the processed events from the stream processor;
a spooler configured to read the processed events from the queue, write the processed events to a buffer, and remove duplicated events in the buffer, the duplicated events including a composite event and an unjoined event processed by the stream processor before the composite event, the composite event including data associated with the unjoined event and data associated with a secondary event received after the unjoined event, the composite event created by the stream processor after receiving the secondary event; and
an auditor process configured to extract a written event from the buffer and confirm that the written event matches an event present in the event stream.
|