CPC H04L 43/045 (2013.01) [H04L 65/60 (2013.01)] | 20 Claims |
15. A method for improved fault tolerance in a streaming architecture, the method comprising:
generating a data partition within a first data table, wherein the first data table is configured to consume data from a stream-processing log and store the consumed data for access by an application server;
reading input parameters from the stream-processing log;
determining a transformation scheme based on the input parameters;
reading a message from the stream-processing log, wherein the message comprises a plurality of data payloads;
verifying that the message is a complete message based on an offset value associated with each data payload of the plurality of data payloads;
applying the transformation scheme to the complete message, generating a transformed message;
storing the transformed message in the data partition; and
monitoring a lag time associated with the transformed message.
|