Question 1

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 2

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 3

Which of the following is the correct command for creating a topic foo with 3 partitions and with a replication factor of 3 ?

Options :

A : bin/kafka-topics-create.sh --zookeeper localhost:9092 --replication-factor 3 --partitions 3 --topic foo

B : bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 3 --topic foo

C : bin/kafka-topics.sh --create --broker localhost:9092 --replication-factor 3 --partitions 3 --topic foo

D : bin/kafka-topics-create.sh --zookeeper localhost:2181 --num-replicas 3 --partitions 3 --topic foo

Answer: B

Question 4

Using the Confluent Schema Registry, where are Avro schema stored?

Options :

A : In the Schema Registry embedded SQL database

B : In the Zookeeper node /schemas

C : In the message bytes themselves

D : In the _schemas topic

Answer: D

Question 5

Which of the following defines HOPPING operation correctly from a KSQL perspective?

Options :

A : Fixed-sized, (possibly) overlapping windows based on the record’s timestamps

B : fixed-sized, non-overlapping windows based on the record-s timestamps

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

D : Sessions with a period of activity and gaps in between

Answer: A

Higher Test Marks with Free Online CCDAK Exam Practice