Question 1

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 2

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

Question 3

Select the Kafka Streams joins that are always windowed joins.

Options :

A : KStream-KStream join

B : KTable-KTable join

C : KStream-GlobalKTable

D : KStream-KTable join

Answer: A

Question 4

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 5

We have a store selling shoes. What dataset is a great candidate to be modeled as a KTable in Kafka Streams?

Options :

A : Money made until now

B : The transaction stream

C : Items returned

D : Inventory contents right now

Answer: A,C