CCDAK Online Practice Questions and Answers

A kafka topic has a replication factor of 3 and min.insync.replicas setting of 2. How many brokers can go down before a producer with acks=all can't produce?

A. 0

B. 2

C. 1

D. 3

Which of these joins does not require input topics to be sharing the same number of partitions?

A. KStream-KTable join

B. KStream-KStream join

C. KStream-GlobalKTable

D. KTable-KTable join

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

Select all that applies (select THREE)

A. min.insync.replicas is a producer setting

B. acks is a topic setting

C. acks is a producer setting

D. min.insync.replicas is a topic setting

E. min.insync.replicas matters regardless of the values of acks

F. min.insync.replicas only matters if acks=all

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

How will you find out all the partitions without a leader?

A. kafka-topics.sh --broker-list localhost:9092 --describe --under-replicated-partitions

B. kafka-topics.sh --bootstrap-server localhost:2181 --describe --unavailable-partitions

C. kafka-topics.sh --zookeeper localhost:2181 --describe --unavailable-partitions

D. kafka-topics.sh --zookeeper localhost:2181 --describe --under-replicated-partitions

How do Kafka brokers ensure great performance between the producers and consumers? (select two)

A. It compresses the messages as it writes to the disk

B. It leverages zero-copy optimisations to send data straight from the page-cache

C. It buffers the messages on disk, and sends messages from the disk reads

D. It transforms the messages into a binary format

E. It does not transform the messages

You are building a consumer application that processes events from a Kafka topic. What is the most important metric to monitor to ensure real-time processing?

A. UnderReplicatedPartitions

B. records-lag-max

C. MessagesInPerSec

D. BytesInPerSec

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

A consumer wants to read messages from partitions 0 and 1 of a topic topic1. Code snippet is shown below.

consumer.subscribe(Arrays.asList("topic1"));

List pc = new ArrayList<>();

pc.add(new PartitionTopic("topic1", 0));

pc.add(new PartitionTopic("topic1", 1));

consumer.assign(pc);

A. This works fine. subscribe() will subscribe to the topic and assign() will assign partitions to the consumer.

B. Throws IllegalStateException

What client protocol is supported for the schema registry? (select two)

A. HTTP

B. HTTPS

C. JDBC

D. Websocket

E. SASL

In Avro, adding an element to an enum without a default is a __ schema evolution

A. breaking

B. full

C. backward

D. forward

What is returned by a producer.send() call in the Java API?

A. Future object

B. A Boolean indicating if the call succeeded

C. Future object

D. Unit

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

If you enable an SSL endpoint in Kafka, what feature of Kafka will be lost?

A. Cross-cluster mirroring

B. Support for Avro format

C. Zero copy

D. Exactly-once delivery