72 real Streaming questions from the Data Engineering bank, as asked in Indian campus drives and tech interviews. Every question has a verified answer and an AI-tutor explanation on placd — free to start.
1. What is watermark?
Mid
A.Streaming computation that retains accumulated state (counts, aggregations, joins) across micro-batches, checkpointed for fault tolerance.
B.A Kafka topic subdivision that provides ordering and parallelism; records with the same key go to the same partition.
C.Two delivery guarantees: at-least-once may duplicate on retry but never loses data; at-most-once never duplicates but may drop data.
D.A heuristic timestamp in a stream processor marking how far event time has progressed, used to decide when a window can close despite late data.
2. Which term means: "A heuristic timestamp in a stream processor marking how far event time has progressed, used to decide when a window can close despite late data."?
A.watermark — The position a consumer group has read to in a partition, committed so processing can resume after a restart without reprocessing.
B.watermark — A heuristic timestamp in a stream processor marking how far event time has progressed, used to decide when a window can close despite late data.
C.watermark — A configured grace period after a window's watermark passes during which late events are still accepted and update the window result.
D.watermark — Event time is when an event actually occurred; processing time is when the system handles it; correct streaming uses event time with watermarks for late data.
A.A series of fixed-size, non-overlapping time windows over a stream, so each event belongs to exactly one window.
B.A Spark Structured Streaming sink that hands each micro-batch to a function as a DataFrame, enabling upserts, multi-sink writes, and arbitrary logic.
C.A named, partitioned, append-only log in Kafka to which producers publish and from which consumer groups read independently.
D.A streaming guarantee that each record affects state and output once despite failures, achieved with checkpointing, idempotent sinks, or transactional writes.
A.tumbling window — A Spark Structured Streaming sink that hands each micro-batch to a function as a DataFrame, enabling upserts, multi-sink writes, and arbitrary logic.
B.tumbling window — A Spark Structured Streaming mechanism that persists offsets and state to durable storage so a failed query resumes exactly where it left off.
C.tumbling window — The position a consumer group has read to in a partition, committed so processing can resume after a restart without reprocessing.
D.tumbling window — A series of fixed-size, non-overlapping time windows over a stream, so each event belongs to exactly one window.
A.A windowing scheme of fixed-size intervals that advance by a smaller step, so windows overlap and an event can fall into several.
B.Overlapping fixed-size windows that advance by a step smaller than the window length, so each event can fall into multiple windows.
C.A Spark Structured Streaming sink that hands each micro-batch to a function as a DataFrame, enabling upserts, multi-sink writes, and arbitrary logic.
D.A Spark Structured Streaming setting controlling batch cadence, with modes like fixed processing-time interval, availableNow, and continuous.
8. Which term means: "Overlapping fixed-size windows that advance by a step smaller than the window length, so each event can fall into multiple windows."?
A.sliding window — Google Cloud's managed, globally scalable message bus for decoupled, at-least-once asynchronous event delivery between services.
B.sliding window — A named, partitioned, append-only log in Kafka to which producers publish and from which consumer groups read independently.
C.sliding window — Overlapping fixed-size windows that advance by a step smaller than the window length, so each event can fall into multiple windows.
D.sliding window — A Spark Structured Streaming trigger that processes all currently available data in multiple batches and then stops, ideal for incremental scheduled jobs.
A.Google Cloud's managed, globally scalable message bus for decoupled, at-least-once asynchronous event delivery between services.
B.A streaming engine's moving estimate of event-time progress that declares when all events up to a timestamp are assumed to have arrived, triggering window output.
C.A Spark Structured Streaming mechanism that persists offsets and state to durable storage so a failed query resumes exactly where it left off.
D.A dynamic window that groups events separated by less than a configured inactivity gap, ideal for user-activity sessionization.
11. Which term means: "A dynamic window that groups events separated by less than a configured inactivity gap, ideal for user-activity sessionization."?
A.session window — Two delivery guarantees: at-least-once may duplicate on retry but never loses data; at-most-once never duplicates but may drop data.
B.session window — Streaming computation that retains accumulated state (counts, aggregations, joins) across micro-batches, checkpointed for fault tolerance.
C.session window — A dynamic window that groups events separated by less than a configured inactivity gap, ideal for user-activity sessionization.
D.session window — A windowing scheme that groups events separated by gaps smaller than a timeout, producing variable-length windows that close after inactivity.
A.Streaming computation that retains accumulated state (counts, aggregations, joins) across micro-batches, checkpointed for fault tolerance.
B.Event time is when an event actually occurred; processing time is when the system handles it; correct streaming uses event time with watermarks for late data.
C.A Spark Structured Streaming sink that hands each micro-batch to a function as a DataFrame, enabling upserts, multi-sink writes, and arbitrary logic.
D.The position a consumer group has read to in a partition, committed so processing can resume after a restart without reprocessing.
14. Which term means: "Event time is when an event actually occurred; processing time is when the system handles it; correct streaming uses event time with watermarks for late data."?
A.event time vs processing time — A flow-control condition where a slow downstream operator forces upstream stages to slow down, preventing unbounded buffering and memory growth.
B.event time vs processing time — A dynamic window that groups events separated by less than a configured inactivity gap, ideal for user-activity sessionization.
C.event time vs processing time — A configured grace period after a window's watermark passes during which late events are still accepted and update the window result.
D.event time vs processing time — Event time is when an event actually occurred; processing time is when the system handles it; correct streaming uses event time with watermarks for late data.
A.Two delivery guarantees: at-least-once may duplicate on retry but never loses data; at-most-once never duplicates but may drop data.
B.A Spark Structured Streaming trigger that processes all currently available data in multiple batches and then stops, ideal for incremental scheduled jobs.
C.Event time is when an event actually occurred; processing time is when the system handles it; correct streaming uses event time with watermarks for late data.
D.A streaming guarantee that each record affects state and output once despite failures, achieved with checkpointing, idempotent sinks, or transactional writes.
17. Which term means: "A streaming guarantee that each record affects state and output once despite failures, achieved with checkpointing, idempotent sinks, or transactional writes."?
A.exactly-once semantics — Two delivery guarantees: at-least-once may duplicate on retry but never loses data; at-most-once never duplicates but may drop data.
B.exactly-once semantics — A streaming guarantee that each record affects state and output once despite failures, achieved with checkpointing, idempotent sinks, or transactional writes.
C.exactly-once semantics — A windowing scheme of fixed-size, non-overlapping time intervals so each event belongs to exactly one window.
D.exactly-once semantics — A dynamic window that groups events separated by less than a configured inactivity gap, ideal for user-activity sessionization.
20. Which term means: "Stream operations (aggregations, joins, dedup) that retain state across events, requiring checkpointing for fault tolerance and recovery."?
A.stateful processing — AWS managed service for real-time streaming data ingestion and processing, with shards as the unit of throughput and ordering.
B.stateful processing — Stream operations (aggregations, joins, dedup) that retain state across events, requiring checkpointing for fault tolerance and recovery.
C.stateful processing — A Spark Structured Streaming trigger that processes all currently available data in multiple batches and then stops, ideal for incremental scheduled jobs.
D.stateful processing — A streaming guarantee that each record affects state and output once despite failures, achieved with checkpointing, idempotent sinks, or transactional writes.
A.A flow-control condition where a slow downstream operator forces upstream stages to slow down, preventing unbounded buffering and memory growth.
B.AWS managed service for real-time streaming data ingestion and processing, with shards as the unit of throughput and ordering.
C.Google Cloud's managed, globally scalable message bus for decoupled, at-least-once asynchronous event delivery between services.
D.A Spark Structured Streaming sink that hands each micro-batch to a function as a DataFrame, enabling upserts, multi-sink writes, and arbitrary logic.
23. Which term means: "A flow-control condition where a slow downstream operator forces upstream stages to slow down, preventing unbounded buffering and memory growth."?
A.backpressure — AWS managed service for real-time streaming data ingestion and processing, with shards as the unit of throughput and ordering.
B.backpressure — A Spark Structured Streaming mechanism that persists offsets and state to durable storage so a failed query resumes exactly where it left off.
C.backpressure — A heuristic timestamp in a stream processor marking how far event time has progressed, used to decide when a window can close despite late data.
D.backpressure — A flow-control condition where a slow downstream operator forces upstream stages to slow down, preventing unbounded buffering and memory growth.
26. Which term means: "AWS managed service for real-time streaming data ingestion and processing, with shards as the unit of throughput and ordering."?
A.A Spark Structured Streaming trigger that processes all currently available data in multiple batches and then stops, ideal for incremental scheduled jobs.
B.Google Cloud's managed, globally scalable message bus for decoupled, at-least-once asynchronous event delivery between services.
C.A windowing scheme of fixed-size intervals that advance by a smaller step, so windows overlap and an event can fall into several.
D.A dynamic window that groups events separated by less than a configured inactivity gap, ideal for user-activity sessionization.
29. Which term means: "Google Cloud's managed, globally scalable message bus for decoupled, at-least-once asynchronous event delivery between services."?
A.Pub/Sub — Google Cloud's managed, globally scalable message bus for decoupled, at-least-once asynchronous event delivery between services.
B.Pub/Sub — A Spark Structured Streaming trigger that processes all currently available data in multiple batches and then stops, ideal for incremental scheduled jobs.
C.Pub/Sub — Streaming computation that retains accumulated state (counts, aggregations, joins) across micro-batches, checkpointed for fault tolerance.
D.Pub/Sub — A dynamic window that groups events separated by less than a configured inactivity gap, ideal for user-activity sessionization.
Showing 30 of 72 Streaming questions — the full set, with answers, explanations and an AI tutor on every question, is inside.
Free to start
Answers, AI explanations, and a scored voice mock interview
Sign up free to check your answers with explanations, ask the AI tutor anything on any question, and take one full AI mock interview — scored like a real panel.