11.) Which method is used to start a Kafka Streams application?
A) start()
B) begin()
C) launch()
D) open()
12.) What is the default offset reset policy in Kafka Streams?
A) latest
B) earliest
C) none
D) reset
13.) A KStream can be converted into a KTable using:
A) map()
B) join()
C) toTable()
D) toKTable()
14.) Which function is used to repartition a stream by key?
A) groupByKey()
B) flatMap()
C) peek()
D) mapValues()
15.) What type of store is backed by RocksDB in Kafka Streams?
A) GlobalStore
B) FileStore
C) Persistent Key-Value Store
D) Memory Store
16.) Which one is NOT a valid Kafka Streams operation?
A) mapValues()
B) merge()
C) reduce()
D) toUpper()
17.) How do you persist aggregated results in Kafka Streams?
A) Use Materialized view
B) tore in ZooKeeper
C) Call flush()
D) Use log compaction
18.) Kafka Streams ensures fault tolerance using:
A) ZooKeeper logs
B) Internal changelog topics
C) Java Serialization
D) ACLs
19.) How are Kafka Streams applications scaled?
A) Adding threads
B) Adding partitions to topics
C) Adding more JVM instances
D) All of the above
20.) What does through() operation do in Kafka Streams?
A) Serializes data
B) Filters nulls
C) Rewrites to an intermediate topic
D) Disconnects the stream
Related
