The Kafka Streams API is a powerful client library in Apache Kafka for building real-time, scalable, and fault-tolerant stream processing applications. Unlike external processing engines, Kafka Streams allows you to embed stream logic directly into your Java applications while offering rich features like windowing, state stores, joins, and exactly-once semantics.
This set of 30 Multiple Choice Questions (MCQs) will help developers and interview test and improve their understanding of Kafka Streams from basic concepts to advanced patterns, including topologies, DSL/Processor APIs, and state management.
1.) What is Kafka Streams API primarily used for?
2.) Kafka Streams API is written in which programming language?
3.) The default programming model in Kafka Streams is called:
4.) Which component in Kafka Streams represents a continuous flow of records?
5.) Which component represents a changelog stream in Kafka Streams?
6.) What is a GlobalKTable used for?
7.) Which interface is used to define the stream logic using the low-level API?
8.) Kafka Streams uses which underlying library for serialization?
9.) Kafka Streams supports which of the following join types?
10.) What is the result type of a groupBy().reduce() operation?