US 12,407,585 B2
Managing dynamic messaging using a Kafka-based monitoring application
Varun Monga, Newark, DE (US); Dan Bodalski, Swedesboro, NJ (US); Nada Ziab, Wilmington, DE (US); and Maxwell Janney, Wilmington, DE (US)
Assigned to JP Morgan Chase Bank, N.A., New York, NY (US)
Filed by JP Morgan Chase Bank, N.A., New York, NY (US)
Filed on Dec. 15, 2023, as Appl. No. 18/541,819.
Prior Publication US 2025/0202782 A1, Jun. 19, 2025
Int. Cl. H04L 41/5025 (2022.01)
CPC H04L 41/5025 (2013.01) 20 Claims
OG exemplary drawing
 
1. A method for managing dynamic messaging using a Kafka-based monitoring application deployed within a cloud environment having at least one software application in operation, the method comprising:
monitoring, via the Kafka-based monitoring application, consumer lag for a specific topic associated with the at least one software application;
scheduling queries, via the Kafka-based monitoring application, to detect consumer lag for the specific topic at predetermined intervals;
detecting, via an application programming interface in communication with the Kafka-based monitoring application, any consumer lag and retrieving a list of any affected consumers and associated consumer information; and
determining one or more pools of the affected consumers, and performing a scaling operation to scale up or down consumers on the one or more pools based on the consumer lag detected.