Streaming Interview Questions

16 real Streaming questions asked in live technical interviews — each with a model answer. Updated weekly.

🎤 Auto-captured by Assisting AI during live interviews

These Streaming interview questions were captured from real interviews by candidates using Assisting AI. Each links to a full model answer. For real-time help during your own interview, get Assisting AI from ₹500/day.

Have you worked with streaming pipelines and batch networks?🟡 Medium · Behavioral · Asked 3×Identify every lane‑change event. A lane change occurs when the lane_id changes from one value to another and the new lane remains stable for at least 1 second. Return session_id, change_timestamp_ms, from_lane, to_lane, and speed_at_change. Additional challenge: include session_id, timestamp_ms, lane_id, and speed for all records.🟡 Medium · Coding · Asked 1×When you say one of the sources is streaming, is the streaming data coming from your internal product or from an external source?🟢 Easy · Conceptual · Asked 1×Can you write a script for watermarking?🟡 Medium · Coding · Asked 1×Consider you are building a streaming job that consumes CDC records from Amazon Kinesis. How do you enforce exactly‑once processing and handle out‑of‑order records?🔴 Hard · System Design · Asked 1×Have you worked on streaming data?🟡 Medium · Conceptual · Asked 1×Have you designed any pipeline for processing streaming data from an implementation perspective?🟡 Medium · Behavioral · Asked 1×How do you handle batch and stream data in AWS?🟡 Medium · Conceptual · Asked 1×How would you handle errors when data is corrupted while working on streaming data?🟡 Medium · Conceptual · Asked 1×Can you tell how to optimize Spark jobs for streaming data?🟡 Medium · Conceptual · Asked 1×What is your experience with near real‑time projects?🟡 Medium · Conceptual · Asked 1×Write a Python function using Apache Spark Structured Streaming that reads messages from a Kafka topic, counts occurrences of each 'event_type' in real time, and writes the result to a BigQuery table. Handle connection and streaming errors gracefully.🔴 Hard · Coding · Asked 1×Count occurrences of each event type in real time, write the result to a BigQuery table, and handle connection and streaming errors.🟡 Medium · Coding · Asked 1×Suppose 500 million transactions occur per day. Design a pipeline to consume these transactions, perform processing, and every hour submit analytics extracted from the data. How would you architect this system?🔴 Hard · System Design · Asked 1×You must implement near‑real‑time ingestion from S3 with schema drift (occasional new columns) while avoiding full listings of the bucket. Badly formed records should land in a quarantine column for triage. Which design is most appropriate on Databricks?🟡 Medium · Conceptual · Asked 1×What is a watermark column?🟢 Easy · Conceptual · Asked 1×

🎤 Get Streaming questions answered in real-time

Assisting AI listens to your interview, captures questions live, and gives you instant AI-powered answers on a discreet on-screen overlay.

Get Assisting AI — Starts at ₹500

Browse Other Topics