Confluent CCDAK Exam Questions Instant Access

Question 1

How will you read all the messages from a topic in your KSQL query?

AKSQL reads from the beginning of a topic, by default.

BKSQL reads from the end of a topic. This cannot be changed.

CUse KSQL CLI to set auto.offset.reset property to earliest

Answer : C

Consumers can set auto.offset.reset property to earliest to start consuming from beginning. For KSQL, SET 'auto.offset.reset'='earliest';

Question 2

What isn't an internal Kafka Connect topic?

Aconnect-status

Bconnect-offsets

Cconnect-configs

Dconnect-jars

Answer : D

connect-configs stores configurations, connect-status helps to elect leaders for connect, and connect-offsets store source offsets for source connectors

Question 3

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

AFuture<ProducerRecord> object

BA Boolean indicating if the call succeeded

CFuture<RecordMetadata> object

DUnit

Answer : C

Seehttps://kafka.apache.org/21/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html

Question 4

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

ACommit the offsets on disk, after processing the data

BDo not commit any offsets and read from beginning

CCommit the offsets in Kafka, after processing the data

DCommit the offsets in Kafka, before processing the data

Answer : D

Here, we must commit the offsets right after receiving a batch from a call to .poll()

Question 5

What is a generic unique id that I can use for messages I receive from a consumer?

Atopic + partition + timestamp

Btopic + partition + offset

Ctopic + timestamp

Answer : B

(Topic,Partition,Offset) uniquely identifies a message in Kafka

Question 6

To enhance compression, I can increase the chances of batching by using

Aacks=all

Blinger.ms=20

Cbatch.size=65536

Dmax.message.size=10MB

Answer : B

linger.ms forces the producer to wait before sending messages, hence increasing the chance of creating batches that can be heavily compressed.

Question 7

You are using JDBC source connector to copy data from 2 tables to two Kafka topics. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers. How many tasks are launched?

Answer : C

we have two tables, so the max number of tasks is 2

Confluent Certified Developer for Apache Kafka CCDAK Exam Questions