Real-time Inventory Consolidation
Debezium CDC from PostgreSQL → Kafka → PyFlink stateful streaming → ClickHouse OLAP. Sub-minute SKU inventory across 1100+ Zepto dark stores.
click anywhere to skip
What I actually do
Every business sits on a pile of scattered, half-trusted information. My job is to clean it, connect it, and turn it into the fuel that decisions, savings, products and AI run on.
I clean it. Connect it. Make it trustworthy.
pipelines · quality · governance
About
Senior Data Engineer with 4+ years building petabyte-scale ETL/ELT pipelines, real-time streaming, and distributed warehousing at Zepto, Nielsen, and Tredence. PySpark, Kafka, Flink, Databricks, AWS & Azure. Reduced incidents 50%, cut infra cost 30–35%, accelerated delivery 30–40%.
Milestones
Hover a stone for a one-line read. Click to step into the full story.
Feb 2025 — Present
Zepto · Bangalore, India
Read storySep 2024 — Jan 2025
Nielsen · Bangalore, India
Read storyJun 2022 — Aug 2024
Tredence Inc. · Bangalore, India
Read story2018 — 2022
NIT Jalandhar · Jalandhar, India
Read storyStack
A curated set across cloud, streaming, batch and orchestration.
Selected Work
Platforms and pipelines designed for throughput, cost, and operability at real production scale.
Debezium CDC from PostgreSQL → Kafka → PyFlink stateful streaming → ClickHouse OLAP. Sub-minute SKU inventory across 1100+ Zepto dark stores.
PySpark + Spark SQL + Delta Lake on S3, Airflow DAGs — single source of truth for FMCG, SuperStore, Cafe & Milk planning.
Diff engine + Delta audit + Databricks RBAC governing 200+ jobs. Multi-stage Docker builds for PyFlink/Debezium cut onboarding to 2 hrs.
OOP Python service over Databricks telemetry with Redis sub-ms threshold lookup and MongoDB alert history.
Connect
@ashish-6204
GitHub
@asisaarav
4+
Years building data
petabyte-scale pipelines
4
Certifications
Databricks · Snowflake · Azure
--:--
Bangalore, India 🇮🇳
IST · my local time
Resume
Download CV