Confluent Certified Developer for Apache Kafka

Here you have the best Confluent CCDAK practice exam questions

You have 70 total questions to study from
Each page has 5 questions, making a total of 14 pages
You can navigate through the pages using the buttons at the bottom
This questions were last updated on January 5, 2026
This site is not affiliated with or endorsed by Confluent.

Question 1 of 70

You need to consume messages from Kafka using the command-line interface (CLI).
Which command should you use?

kafka-console-consumer

kafka-consumer

kafka-get-message

kafka- consume

Correct Answer: A

Question 2 of 70

You are experiencing low throughput from a Java producer. You monitor the Kafka metrics and notice that the metrics for that producer show low I/O thread ratio and low I/O thread wait ratio.
What is the most likely the cause of the slow producer performance?

Compression is enabled.

The producer is sending large batches of messages.

There is a bad data link layer (layer 2) connection from the producer to the cluster.

The producer code has an expensive callback function.

Correct Answer: D

Question 3 of 70

Which configuration is valid for deploying a JDBC Source Connector to read all the rows from orders table and write it to db1-orders topic?

{
"name":"jdbc-source",
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max": "1",
"connection.url": "jdbc:mysql://mysql:3306/db1?user=user&password=password&useSSL=false",
"topic.prefix": "db1-",
"table.whitelist": "orders"
}

{
"name":"db1-orders".
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max": "1",
"connection.url": "jdbc:mysql://mysql:3306/db1?user=user&password=password&useSSL=false",
"topic.prefix": "db1-",
"table.blacklist": "ord*"
}

{
"name":"orders-connect",
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max": "1",
"connection.url": "jdbc:mysql://mysql:3306/db1",
"topic.whitelist": "orders",
"auto.create": "true"
}

{
"name":"jdbc-source",
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max": "1",
"connection.url": "jdbc:mysql://mysql:3306/db1?user=user&useAutoAuthentication=true", "topic.prefix": "db1-",
"table.whitelist": "orders"
}

Correct Answer: A

Question 4 of 70

You are developing a Kafka Streams application with a complex topology that has multiple sources, processors, sinks, and sub-topologies. You are working in a development environment and do not have access to a real Kafka Cluster or Topic.
You need to perform Unit Test on your Kafka Streams application.
Which should you use?

TopologyTestDriver

MockProducer, MockConsumer

TestProducer, TestСonsumer

KafkaUnitTestDriver

Correct Answer: A

Question 5 of 70

Which two statements are correct about transactions in Kafka? (Choose two.)

All messages from a failed transaction will be deleted from a Kafka topic.

Transactions are only possible when writing messages to a topic with single partition.

Consumers can consume both committed and uncommitted transactions.

Information about producers and their transactions is stored in the '__transaction_state' topic.

Transactions guarantee at least once delivery of messages.

Correct Answer: C, D