Confluent CCDAK Exam Practice Test Instant Access

Question 1

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

AKafka Producer

BKafka Streams

CKafka Connect Sink

DKafka Connect Source

Answer : C

Kafka Connect Sink is used to export data from Kafka to external databases and Kafka Connect Source is used to import from external databases into Kafka.

Question 2

If I want to send binary data through the REST proxy, it needs to be base64 encoded. Which component needs to encode the binary data into base 64?

AThe Producer

BThe Kafka Broker

CZookeeper

DThe REST Proxy

Answer : A

The REST Proxy requires to receive data over REST that is already base64 encoded, hence it is the responsibility of the producer

Question 3

What's is true about Kafka brokers and clients from version 0.10.2 onwards?

AClients and brokers must have the exact same version to be able to communicate

BA newer client can talk to a newer broker, but an older client cannot talk to a newer broker

CA newer client can talk to a newer broker, and an older client can talk to a newer broker

DA newer client can't talk to a newer broker, but an older client can talk to a newer broker

Answer : C

Kafka's new bidirectional client compatibility introduced in 0.10.2 allows this. Read more herehttps://www.confluent.io/blog/upgrading-apache-kafka-clients-just-got-easier/

Question 4

How will you set the retention for the topic named my-topic to 1 hour?

ASet the broker config log.retention.ms to 3600000

BSet the consumer config retention.ms to 3600000

CSet the topic config retention.ms to 3600000

DSet the producer config retention.ms to 3600000

Answer : C

retention.ms can be configured at topic level while creating topic or by altering topic. It shouldn't be set at the broker level (log.retention.ms) as this would impact all the topics in the cluster, not just the one we are interested in

Question 5

A consumer has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group never committed offsets for the topic before. Where will the consumer read from?

Aoffset 2311

Boffset 0

Coffset 45

Dit will crash

Answer : A

Latest means that data retrievals will start from where the offsets currently end

Question 6

Your streams application is reading from an input topic that has 5 partitions. You run 5 instances of your application, each with num.streams.threads set to 5. How many stream tasks will be created and how many will be active?

A5 created, 1 active

B5 created, 5 active

C25 created, 25 active

D25 created, 5 active

Answer : D

One partition is assigned a thread, so only 5 will be active, and 25 threads (i.e. tasks) will be created

Question 7

Your manager would like to have topic availability over consistency. Which setting do you need to change in order to enable that?

Acompression.type

Bunclean.leader.election.enable

Cmin.insync.replicas

Answer : B

unclean.leader.election.enable=true allows non ISR replicas to become leader, ensuring availability but losing consistency as data loss will occur

Confluent Certified Developer for Apache Kafka Exam Practice Test