Free CCDAK Questions for Confluent Certified Developer for Apache Kafka Certification Examination CCDAK Exam as PDF & Practice Test Engine

Exam Code/Number: CCDAK
Exam Name/Title: Confluent Certified Developer for Apache Kafka Certification Examination
Certification Provider: Confluent
Corresponding Certification: Confluent Certified Developer

Exam Questions: 92
Updated On: Aug 25, 2026

Question #1

Which two statements are correct when assigning partitions to the consumers in a consumer group using the assign() API?
(Select two.)

A. All topics must have the same number of partitions to use assign() API.

B. It is mandatory to subscribe to a topic before calling assign() to assign partitions.

C. The consumer chooses which partition to read without any assignment from brokers.

D. The consumer group will not be rebalanced if a consumer leaves the group.

Discussion 0

Correct Answer: C,D Vote an answer

Explanation: Only visible for ExamDiscuss members. You can sign-up / login (it's free).

Question #2

You have a consumer group with default configuration settings reading messages from your Kafka cluster.
You need to optimize throughput so the consumer group processes more messages in the same amount of time.
Which change should you make?

A. Increase the number of bytes the consumers read with each fetch request.

B. Disable auto commit and have the consumers manually commit offsets.

C. Decrease the session timeout of each consumer.

D. Remove some consumers from the consumer group.

Discussion 0

Correct Answer: A Vote an answer

Explanation: Only visible for ExamDiscuss members. You can sign-up / login (it's free).

Question #3

Which is true about topic compaction?

A. When a client produces a new event with an existing key, the old value is overwritten with the new value in the compacted log segment.

B. Topic compaction does not remove old events; instead, when clients consume events from a compacted topic, they store events in a hashmap that maintains the latest value.

C. Compaction will keep exactly one message per key after compaction of inactive log segments.

D. When a client produces a new event with an existing key, the broker immediately deletes the offset of the existing event.

Discussion 0

Correct Answer: C Vote an answer

Explanation: Only visible for ExamDiscuss members. You can sign-up / login (it's free).

Question #4

(Which configuration determines the maximum number of records a consumer can poll in a single call to poll()?)

A. fetch.max.records

B. max.poll.records

C. max.poll.records.interval

D. max.records.consumer

Discussion 0

Correct Answer: B Vote an answer

Explanation: Only visible for ExamDiscuss members. You can sign-up / login (it's free).

Question #5

(You are building real-time streaming applications using Kafka Streams.
Your application has a custom transformation.
You need to define custom processors in Kafka Streams.
Which tool should you use?)

A. Kafka Streams Custom Transformation Language

B. Processor API

C. TopologyTestDriver

D. Kafka Streams Domain Specific Language (DSL)

Discussion 0

Correct Answer: B Vote an answer

Explanation: Only visible for ExamDiscuss members. You can sign-up / login (it's free).

Question #6

(You are writing to a Kafka topic with producer configuration acks=all.
The producer receives acknowledgements from the broker but still creates duplicate messages due to network timeouts and retries.
You need to ensure that duplicate messages are not created.
Which producer configuration should you set?)

A. retries=2147483647max.in.flight.requests.per.connection=1enable.idempotence=true

B. retries=0max.in.flight.requests.per.connection=5enable.idempotence=true

C. enable.auto.commit=true

D. retries=2147483647max.in.flight.requests.per.connection=5enable.idempotence=false

Discussion 0

Correct Answer: A Vote an answer

Explanation: Only visible for ExamDiscuss members. You can sign-up / login (it's free).

Question #7

What are three built-in abstractions in the Kafka Streams DSL?
(Select three.)

A. KTable

B. KStream

C. StreamTable

D. GlobalKStream

E. GlobalKTable

Discussion 0

Correct Answer: A,B,E Vote an answer

Explanation: Only visible for ExamDiscuss members. You can sign-up / login (it's free).

Question #8

You have a Kafka consumer in production actively reading from a critical topic.
You need to update the offset of your consumer to start reading from the beginning of the topic.
Which action should you take?

A. Start a new consumer application with the same consumer group id.

B. Update the consumer group's offset to the earliest position using the kafka-consumer-groups CLI tool.

C. Update the consumer configuration by setting auto.offset.reset=earliest.

D. Temporarily configure the topic's retention.ms parameter to 0 to empty the topic.

Discussion 0

Correct Answer: B Vote an answer

Explanation: Only visible for ExamDiscuss members. You can sign-up / login (it's free).

Question #9

Match the testing tool with the type of test it is typically used to perform.

Discussion 0

Correct Answer:

Explanation:
Unit Testing # MockProducer
Integration Testing # Testcontainers
Performance Testing # Trogdor
Mock Data Generation # Connect Datagen
MockProducer: Simulates a Kafka producer in unit tests (no real broker interaction).
Testcontainers: Spawns Kafka in Docker for real environment testing.
Trogdor: Kafka's built-in performance load testing framework.
Connect Datagen: Creates sample source records for test and demo purposes.
From Kafka Developer Tools Guide:
"Kafka developers commonly use MockProducer for unit tests, Testcontainers for integration, and Trogdor for performance tests." Reference: Kafka Testing and Tools Overview

Question #10

(You have a Kafka Connect cluster with multiple connectors deployed.
One connector is not working as expected.
You need to find logs related to that specific connector to investigate the issue.
How can you find the connector's logs?)

A. Change the log level to DEBUG to include connector context information.

B. Modify the log4j.properties file to add a dedicated log appender for the connector.

C. Modify the log4j.properties file to enable connector context.

D. Make no change; there is no way to isolate connector logs.

Discussion 0

Correct Answer: B Vote an answer

Explanation: Only visible for ExamDiscuss members. You can sign-up / login (it's free).

Free CCDAK Questions for Confluent Certified Developer for Apache Kafka Certification Examination CCDAK Exam as PDF & Practice Test Engine

Download Free Confluent CCDAK Demo