Koteswararao Dokkari

Python Developer and Data Engineer with hands-on experience in real-time streaming (Kafka, Confluent Cloud), batch ETL (Snowflake, Matillion, Redshift, AWS) and backend development (Django, FastAPI, REST APIs). Interned at Dehaze Labs on a production Kafka pipeline (~150K events/day), where I split a dual-database enricher into single-sink services and helped investigate and recover a 10.5-hour data gap (~63K records). Earlier delivered a DB2-to-Snowflake migration for Daimler Trucks North America.

Strong in SQL, Python, AWS, Docker and CI/CD, with working knowledge of NLP and LLM tooling.

Data Engineer Intern at Dehaze Labs (2026-02 – 2026-04)

Real-time Discord analytics platform | Kafka, Redshift, TimescaleDB, Python

• Worked on a production Kafka (Confluent Cloud) pipeline handling ~150K events/day, with Python consumers writing to TimescaleDB and Amazon Redshift using Schema Registry serialization.
• Split a combined dual-database enricher (Spotify + Game presence data) into separate TimescaleDB and Redshift services, working mainly on the Spotify enrichment path; verified data in both databases after the AWS ECS deployment.
• Investigated a 10.5-hour production data gap (~63K records): confirmed it with SQL window functions (LAG) and showed the data never reached the Kafka topic by checking offsets and timestamps with a read-only consumer.
• Recovered the missing data from TimescaleDB into Redshift using a staging-table anti-join upsert (no duplicates), converting ARRAY/JSONB columns to VARCHAR.
• Built a pandas reconciliation script (composite-key comparison) that caught 70 residual missing records.

AWS Intern – Python Developer at ExcelR (2024-06 – 2024-12)

Client: Daimler Trucks North America (Online Warranty Link system)

• Migrated legacy data from IBM DB2 to Snowflake using Matillion ETL, supporting a multi-terabyte migration.
• Built views, stored procedures, staging tables and aggregation logic enforcing business validation rules; designed Matillion orchestration jobs automating daily flows from Snowflake to Salesforce.
• Wrote Python reconciliation scripts comparing source vs. target outputs and maintained mismatch-tracking sheets, catching data issues earlier and cutting manual verification.
• Scheduled and monitored UTC-based CRON jobs for daily loads; worked with QA and business analysts to turn validation rules into ETL logic and post-migration tests.

B.Tech in Computer Science and Engineering – JNTU Vijayanagaram (2022-06 – 2026-04)