Free CCDAK: Confluent Certified Developer for Apache Kafka Certification Examination Exam Questions and Answers
135 verified practice questions for CCDAK.
The first 10 questions on this page are free to read, answers included — no account and no card. A plan opens the rest of the bank, the full timed practice test and your weak-topic reporting.
Last updated: September 19, 2026
- Exam code
- CCDAK
- Provider
- Confluent
- Questions in our bank
- 1000+
- Free to read
- First 10, with answers
- Our test mode duration & pass mark
- 130 mins · 70%
- Verified answers
- Reviewed weekly
Recommended: Switch to Test Mode to start a practice test that simulates the real exam experience.
Question #1
is KSQL ANSI SQL compliant?
Please select an optionIncorrectCorrect answer: B
KSQL is not ANSI SQL compliant, for now there are no defined standards on streaming SQL languages
Was this answer correct?Question #2
In Kafka Streams, by what value are internal topics prefixed by?
Please select an optionIncorrectCorrect answer: B
In Kafka Streams, the application.id is also the underlying group.id for your consumers, and the prefix for all internal topics (repartition and state)
Was this answer correct?Question #3
A consumer starts and has auto.offset.reset=none, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 10 for the topic before. Where will the consumer read from?
Please select an optionIncorrectCorrect answer: C
auto.offset.reset=none means that the consumer will crash if the offsets it's recovering from have been deleted from Kafka, which is the case here, as 10 < 45
Was this answer correct?Question #4
What exceptions may be caught by the following producer? (select two) ProducerRecord<String, String> record = new ProducerRecord<>("topic1", "key1", "value1"); try { producer.send(record); } catch (Exception e) { e.printStackTrace(); }
Select 2 answers.
Please select an optionIncorrectCorrect answer: B, D
These are the client side exceptions that may be encountered before message is sent to the broker, and before a future is returned by the .send() method.
Was this answer correct?Question #5
A bank uses a Kafka cluster for credit card payments. What should be the value of the property unclean.leader.election.enable?
Please select an optionIncorrectCorrect answer: A
Setting unclean.leader.election.enable to true means we allow out-of-sync replicas to become leaders, we will lose messages when this occurs, effectively losing credit card payments and making our customers very angry.
Was this answer correct?Question #6
When using the Confluent Kafka Distribution, where does the schema registry reside?
Please select an optionIncorrectCorrect answer: A
Schema registry is a separate application that provides RESTful interface for storing and retrieving Avro schemas.
Was this answer correct?Question #7
Which Kafka CLI should you use to consume from a topic?
Please select an optionIncorrectCorrect answer: A
Examplekafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic test --from- beginning
Was this answer correct?Question #8
In Avro, removing or adding a field that has a default is a schema evolution
Please select an optionIncorrectCorrect answer: A
Clients with new schema will be able to read records saved with old schema and clients with old schema will be able to read records saved with new schema.
Was this answer correct?Question #9
You have a consumer group of 12 consumers and when a consumer gets killed by the process management system, rather abruptly, it does not trigger a graceful shutdown of your consumer. Therefore, it takes up to 10 seconds for a rebalance to happen. The business would like to have a 3 seconds rebalance time. What should you do? (select two)
Select 2 answers.
Please select an optionIncorrectCorrect answer: B, F
session.timeout.ms must be decreased to 3 seconds to allow for a faster rebalance, and the heartbeat thread must be quicker, so we also need to decrease heartbeat.interval.ms
Was this answer correct?Question #10
There are 3 brokers in the cluster. You want to create a topic with a single partition that is resilient to one broker failure and one broker maintenance. What is the replication factor will you specify while creating the topic?
Please select an optionIncorrectCorrect answer: B
1 is not possible as it doesn't provide resilience to failure, 2 is not enough as if we take a broker down for maintenance, we cannot tolerate a broker failure, and 6 is impossible as we only have 3 brokers (RF cannot be greater than the number of brokers). Here the correct answer is 3
Was this answer correct?
Continue with CCDAK: Confluent Certified Developer for Apache Kafka Certification Examination
Unlock the full question bank
You have read the first 10 questions. A subscription opens every question in CCDAK: Confluent Certified Developer for Apache Kafka Certification Examination, the full timed practice test, and your progress and weak-topic reporting.
Single exam
$19.99for 30 days
Full question bank and practice test for one exam, for 30 days.
Single exam
$49.99for 1 year
One exam for a full year. Nothing renews and nothing to cancel.
Full access
$39.99/mo
Every exam in the catalogue, month to month.
Full access
$199.99/yr
Every exam in the catalogue for a year.
Already subscribed? Sign in to pick up where you left off.
Reviews
★★★★★
This platform is a lifesaver. The practice questions and explanations are so detailed. It’s the best study tool I’ve ever used.
Hannah Smith
USA
★★★★★
I highly recommend Exam Practice. The feedback after each test helped me improve significantly, and I passed my exams easily.
Oscar Nyström
Sweden
★★★★★
Exam Practice is worth every penny. The mock exams are realistic, and the feedback helped me focus on key areas.
Amit Sharma
India