At Lentra AI, I built and optimized Apache Flink applications for the Nudge System, processing customer events to evaluate eligibility for personalized loan offers in real time. I implemented stateful processing, event-time and windowing logic, and fault-tolerance mechanisms to support reliable offer delivery.
At Lentra AI, I also worked on Cadenz Dedupe, integrating Kafka ingestion with Python-based AWS Lambda processing, DynamoDB, and OpenSearch. Earlier at Zielotech Infosolutions India LLP, I developed Spark ETL pipelines and Structured Streaming jobs for batch and delta data.

