CCDAK Online Practice Questions and Answers

Where are the dynamic configurations for a topic stored?

A. In Zookeeper

B. In an internal Kafka topic __topic_configuratins

C. In server.properties

D. On the Kafka broker file system

Which actions will trigger partition rebalance for a consumer group? (select three)

A. Increase partitions of a topic

B. Remove a broker from the cluster

C. Add a new consumer to consumer group

D. A consumer in a consumer group shuts down Add a broker to the cluster

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

You have a Kafka cluster and all the topics have a replication factor of 3. One intern at your company stopped a broker, and accidentally deleted all the data of that broker on the disk. What will happen if the broker is restarted?

A. The broker will start, and other topics will also be deleted as the broker data on the disk got deleted

B. The broker will start, and won't be online until all the data it needs to have is replicated from other leaders

C. The broker will crash

D. The broker will start, and won't have any data. If the broker comes leader, we have a data loss

Which of the following is not an Avro primitive type?

A. string

B. long

C. int

D. date

E. null

To prevent network-induced duplicates when producing to Kafka, I should use

A. max.in.flight.requests.per.connection=1

B. enable.idempotence=true

C. retries=200000

D. batch.size=1

A consumer wants to read messages from a specific partition of a topic. How can this be achieved?

A. Call subscribe(String topic, int partition) passing the topic and partition number as the arguments

B. Call assign() passing a Collection of TopicPartitions as the argument

C. Call subscribe() passing TopicPartition as the argument

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

We would like to be in an at-most once consuming scenario. Which offset commit strategy would you recommend?

A. Commit the offsets on disk, after processing the data

B. Do not commit any offsets and read from beginning

C. Commit the offsets in Kafka, after processing the data

D. Commit the offsets in Kafka, before processing the data

To produce data to a topic, a producer must provide the Kafka client with...

A. the list of brokers that have the data, the topic name and the partitions list

B. any broker from the cluster and the topic name and the partitions list

C. all the brokers from the cluster and the topic name

D. any broker from the cluster and the topic name