Confluent CCDAK Exam Practice Test Instant Access

Question 1

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

A3 replicas of the same data will live on 1 broker

BEach partition will live on 4 different brokers

CEach partition will live on 2 different brokers

DEach partition will live on 3 different brokers

Answer : D

Replicas are spread across available brokers, and each replica = one broker. RF 3 = 3 brokers

Question 2

A Zookeeper ensemble contains 5 servers. What is the maximum number of servers that can go missing and the ensemble still run?

Answer : C

majority consists of 3 zk nodes for 5 nodes zk cluster, so 2 can fail

Question 3

Select all the way for one consumer to subscribe simultaneously to the following topics - topic.history, topic.sports, topic.politics? (select two)

Aconsumer.subscribe(Pattern.compile('topic\..*'));

Bconsumer.subscribe('topic.history'); consumer.subscribe('topic.sports'); consumer.subscribe('topic.politics');

Cconsumer.subscribePrefix('topic.');

Dconsumer.subscribe(Arrays.asList('topic.history', 'topic.sports', 'topic.politics'));

Answer : A, D

Multiple topics can be passed as a list or regex pattern.

Question 4

Once sent to a topic, a message can be modified

ANo

BYes

Answer : A

Kafka logs are append-only and the data is immutable

Question 5

Your topic is log compacted and you are sending a message with the key K and value null. What will happen?

AThe broker will delete all messages with the key K upon cleanup

BThe producer will throw a Runtime exception

CThe broker will delete the message with the key K and null value only upon cleanup

DThe message will get ignored by the Kafka broker

Answer : A

Sending a message with the null value is called a tombstone in Kafka and will ensure the log compacted topic does not contain any messages with the key K upon compaction

Question 6

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

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

Bany broker from the cluster and the topic name and the partitions list

Call the brokers from the cluster and the topic name

Dany broker from the cluster and the topic name

Answer : D

All brokers can respond to a Metadata request, so a client can connect to any broker in the cluster and then figure out on its own which brokers to send data to.

Question 7

StreamsBuilder builder = new StreamsBuilder();

KStream textLines = builder.stream("word-count-input");

KTable wordCounts = textLines

.mapValues(textLine -> textLine.toLowerCase())

.flatMapValues(textLine -> Arrays.asList(textLine.split("\W+")))

.selectKey((key, word) -> word)

.groupByKey()

.count(Materialized.as("Counts"));

wordCounts.toStream().to("word-count-output", Produced.with(Serdes.String(), Serdes.Long()));

builder.build();

What is an adequate topic configuration for the topic word-count-output?

Amax.message.bytes=10000000

Bcleanup.policy=delete

Ccompression.type=lz4

Dcleanup.policy=compact

Answer : D

Result is aggregated into a table with key as the unique word and value its frequency. We have to enable log compaction for this topic to align the topic's cleanup policy with KTable semantics.

Confluent Certified Developer for Apache Kafka CCDAK Exam Practice Test