US 12,261,755 B1
Streaming architecture for improved fault tolerance
Arpan Agrawal, McKinney, TX (US); Sachin Bansode, Madhya Pradesh (IN); Anshul Jain, Madhya Pradesh (IN); and Dinesh Kumar Kanchi Sridharan, Tamil Nadu (IN)
Assigned to BANK OF AMERICA CORPORATION, Charlotte, NC (US)
Filed by BANK OF AMERICA CORPORATION, Charlotte, NC (US)
Filed on Sep. 22, 2023, as Appl. No. 18/371,713.
Int. Cl. G06F 15/173 (2006.01); H04L 43/045 (2022.01); H04L 65/60 (2022.01)
CPC H04L 43/045 (2013.01) [H04L 65/60 (2013.01)] 20 Claims
OG exemplary drawing
 
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.