CCDAK Online Practice Questions and Answers

A client connects to a broker in the cluster and sends a fetch request for a partition in a topic. It gets an exception Not Leader For Partition Exception in the response. How does client handle this situation?

A. Get the Broker id from Zookeeper that is hosting the leader replica and send request to it

B. Send metadata request to the same broker for the topic and select the broker hosting the leader replica

C. Send metadata request to Zookeeper for the topic and select the broker hosting the leader replica

D. Send fetch request to each Broker in the cluster

To continuously export data from Kafka into a target database, I should use

A. Kafka Producer

B. Kafka Streams C. Kafka Connect Sink

D. Kafka Connect Source

To transform data from a Kafka topic to another one, I should use

A. Kafka Connect Sink

B. Kafka Connect Source

C. Consumer + Producer

D. Kafka Streams

How does a consumer commit offsets in Kafka?

A. It directly sends a message to the __consumer_offsets topic

B. It interacts with the Group Coordinator broker

C. It directly commits the offsets in Zookeeper

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

A. Money made until now

B. The transaction stream

C. Items returned

D. Inventory contents right now

The Controller is a broker that is... (select two)

A. elected by Zookeeper ensemble

B. is responsible for partition leader election

C. elected by broker majority

D. is responsible for consumer group rebalances

What's a Kafka partition made of?

A. One file and one index

B. One file

C. One file and two indexes per segment

D. One file and two indexes

A topic has three replicas and you set min.insync.replicas to 2. If two out of three replicas are not available, what happens when a produce request with acks=all is sent to broker?

A. NotEnoughReplicasException will be returned

B. Produce request is honored with single in-sync replica

C. Produce request will block till one of the two unavailable partition is available again.

Which KSQL queries write to Kafka?

A. COUNT and JOIN

B. SHOW STREAMS and EXPLAIN statements

C. CREATE STREAM WITH and CREATE TABLE WITH

D. CREATE STREAM AS SELECT and CREATE TABLE AS SELECT

If a topic has a replication factor of 3...

A. 3 replicas of the same data will live on 1 broker

B. Each partition will live on 4 different brokers

C. Each partition will live on 2 different brokers

D. Each partition will live on 3 different brokers