Question 1

Which of the following are run modes for Kafka Connect [Choose Two]

Options :

A : YARN

B : Local

C : Mesos

D : Distribtued

E : Standalone

Answer: A,D

Question 2

How to temporarily stop consumption of new messages and resume it at a later point:

Options :

A : Stopping consumption temporarily is not possible

B : Use consumer.pause(message) and consumer.resume(message)

C : Use consumer.pause(topic) and consumer.resume(topic)

D : Use consumer.pause(partitions) and consumer.resume(partitions)

Answer: D

Question 3

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 4

Where does Kafka Connector for Filestream Source track its offset

Options :

A : HDFS File

B : Kafka Broker

C : Zookeeper

D : Special Kafka Topic

E : Local File

Answer: A

Question 5

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