Question 1

Which of the following defines flatMapValues operation correctly from a Streaming Application perspective?

Options :

A : Creates a new KStream by transforming each element in the current stream into a different element in the new stream

B : Creates a new KStream by transforming the value of each element in the current stream into zero or more different elements in the new stream

C : Takes one record and produces zero, one, or more records. You can modify the record keys and values, including their types.

D : Creates a new KStream by transforming the value of each element in the current stream into a different element in the new stream

Answer: B

Question 2

A producer is sending messages with null key to a topic with 6 partitions using the DefaultPartitioner. Where will the messages be stored?

Options :

A : Partition 5

B : Any of the topic partitions

C : The partition for the null key

D : Partition 0

Answer: A

Question 3

What does delivery.timeout.ms define in Kafka?

Options :

A : Maximum time client will wait for the response.

B : Timeout after which producer would retry.

C : Maximum time to wait for success or failure after send request.

D : Amount of time to wait before attempting retry.

Answer: C

Question 4

Where does Kafka Connect run

Options :

A : Own dedicated cluster

B : Kafka Producers

C : Kafka Consumers

D : Kafka Brokers

E : Zookeeper

Answer: A

Question 5

In a KafkaProducer program our send() was configured with a callback onCompletion. The send was called and the callback parameters has RecordMetadata object that was null. What does this tell us about send method:

Options :

A : Object metadata being null means there was an error during send

B : Object metadata being null means the transfer was successful

C : Object metadata being null is not enough information to determine if transfer was successful or not

Answer: A