Aug 2025 – Present · 7 mos

• Developed a document storage API(Django REST Framework) for user KYC
• documents and profile images with GCS , signed URLs, and public CDN access,
• cutting average file retrieval time by >70%.
• Developed REST APIs for Kafka Connectors,
• enabling self-serve management of Debezium connectors without manual Kafka cluster access.
• Built CRUD APIs (Django REST Framework) for managing WarehouseConfig
• metadata, enabling dynamic sync scheduling across multiple databases and
• tables.
• Built an Elasticsearch sync service consuming 50K+ Kafka events per batch and indexing documents with dynamic time-based indices, enabling sub-second search latency for time series analytics.

Jun 2025 – Aug 2025 · 2 mos

• Optimized API performance via streaming, MIME-type detection, and schema validation, increasing upload success rate to 99.9% with support for image, video, audio, and application formats.
• Designed and deployed a scalable Kafka-to-S3 ingestion pipeline , processing 100K+ request/response log events daily with Parquet compression and configurable partitioning(hourly/daily/monthly), improving Athena query performance by 40%.
• Implemented Kafka null-event based auto-flush triggers,reducing in-memory buffer time from 10 minutes to <2 minutes , ensuring 100% reliable event delivery.