Confluent CCDAK Confluent Certified Developer for Apache Kafka Certification Examination Online Training
Confluent CCDAK Online Training
The questions for CCDAK were last updated at Nov 01,2025.
- Exam Code: CCDAK
- Exam Name: Confluent Certified Developer for Apache Kafka Certification Examination
- Certification Provider: Confluent
- Latest update: Nov 01,2025
A Zookeeper ensemble contains 3 servers.
Over which ports the members of the ensemble should be able to communicate in default configuration? (select three)
- A . 2181
- B . 3888
- C . 443
- D . 2888
- E . 9092
- F . 80
A client connects to a broker in the cluster and sends a fetch request for a partition in a topic. It gets an exception Not Leader For Partition Exception in the response .
How does client handle this situation?
- A . Get the Broker id from Zookeeper that is hosting the leader replica and send request to it
- B . Send metadata request to the same broker for the topic and select the broker hosting the leader replica
- C . Send metadata request to Zookeeper for the topic and select the broker hosting the leader replica
- D . Send fetch request to each Broker in the cluster
If I supply the setting compression.type=snappy to my producer, what will happen? (select two)
- A . The Kafka brokers have to de-compress the data
- B . The Kafka brokers have to compress the data
- C . The Consumers have to de-compress the data
- D . The Consumers have to compress the data
- E . The Producers have to compress the data
If I produce to a topic that does not exist, and the broker setting auto.create.topic.enable=true, what will happen?
- A . Kafka will automatically create the topic with 1 partition and 1 replication factor
- B . Kafka will automatically create the topic with the indicated producer settings num.partitions and default.replication.factor
- C . Kafka will automatically create the topic with the broker settings num.partitions and default.replication.factor
- D . Kafka will automatically create the topic with num.partitions=#of brokers and replication.factor=3
How will you read all the messages from a topic in your KSQL query?
- A . KSQL reads from the beginning of a topic, by default.
- B . KSQL reads from the end of a topic. This cannot be changed.
- C . Use KSQL CLI to set auto.offset.reset property to earliest
The kafka-console-consumer CLI, when used with the default options
- A . uses a random group id
- B . always uses the same group id
- C . does not use a group id
A producer is sending messages with null key to a topic with 6 partitions using the DefaultPartitioner. Where will the messages be stored?
- A . Partition 5
- B . Any of the topic partitions
- C . The partition for the null key
- D . Partition 0
Which of the following Kafka Streams operators are stateless? (select all that apply)
- A . map
- B . filter
- C . flatmap
- D . branch
- E . groupBy
- F . aggregate
Suppose you have 6 brokers and you decide to create a topic with 10 partitions and a replication factor of 3. The brokers 0 and 1 are on rack A, the brokers 2 and 3 are on rack B, and the brokers 4 and 5 are on rack C. If the leader for partition 0 is on broker 4, and the first replica is on broker 2, which broker can host the last replica? (select two)
- A . 6
- B . 1
- C . 2
- D . 5
- E . 0
- F . 3
Your topic is log compacted and you are sending a message with the key K and value null .
What will happen?
- A . The broker will delete all messages with the key K upon cleanup
- B . The producer will throw a Runtime exception
- C . The broker will delete the message with the key K and null value only upon cleanup
- D . The message will get ignored by the Kafka broker
Latest CCDAK Dumps Valid Version with 150 Q&As
Latest And Valid Q&A | Instant Download | Once Fail, Full Refund
