Confluent CCDAK Confluent Certified Developer for Apache Kafka Certification Examination Online Training
Confluent CCDAK Online Training
The questions for CCDAK were last updated at May 12,2025.
- Exam Code: CCDAK
- Exam Name: Confluent Certified Developer for Apache Kafka Certification Examination
- Certification Provider: Confluent
- Latest update: May 12,2025
A kafka topic has a replication factor of 3 and min.insync.replicas setting of 1 .
What is the maximum number of brokers that can be down so that a producer with acks=all can still produce to the topic?
- A . 3
- B . 0
- C . 2
- D . 1
You have a Kafka cluster and all the topics have a replication factor of 3. One intern at your company stopped a broker, and accidentally deleted all the data of that broker on the disk .
What will happen if the broker is restarted?
- A . The broker will start, and other topics will also be deleted as the broker data on the disk got deleted
- B . The broker will start, and won’t be online until all the data it needs to have is replicated from other leaders
- C . The broker will crash
- D . The broker will start, and won’t have any data. If the broker comes leader, we have a data loss
A consumer application is using KafkaAvroDeserializer to deserialize Avro messages .
What happens if message schema is not present in AvroDeserializer local cache?
- A . Throws SerializationException
- B . Fails silently
- C . Throws DeserializationException
- D . Fetches schema from Schema Registry
In the Kafka consumer metrics it is observed that fetch-rate is very high and each fetch is small .
What steps will you take to increase throughput?
- A . Increase fetch.max.wait
- B . Increase fetch.max.bytes
- C . Decrease fetch.max.bytes
- D . Decrease fetch.min.bytes
- E . Increase fetch.min.bytes
In Avro, removing or adding a field that has a default is a __ schema evolution
- A . full
- B . backward
- C . breaking
- D . forward
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)
- A . Increase session.timeout.ms
- B . Decrease session.timeout.ms
- C . Increase heartbeat.interval.ms
- D . decrease max.poll.interval.ms
- E . increase max.poll.interval.ms
- F . Decrease heartbeat.interval.ms
A consumer starts and has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 643 for the topic before.
Where will the consumer read from?
- A . it will crash
- B . offset 2311
- C . offset 643
- D . offset 45
You are receiving orders from different customer in an "orders" topic with multiple partitions. Each message has the customer name as the key. There is a special customer named ABC that generates a lot of orders and you would like to reserve a partition exclusively for ABC. The rest of the message should be distributed among other partitions .
How can this be achieved?
- A . Add metadata to the producer record
- B . Create a custom partitioner
- C . All messages with the same key will go the same partition, but the same partition may have messages with different keys. It is not possible to reserve
- D . Define a Kafka Broker routing rule
A Zookeeper ensemble contains 5 servers .
What is the maximum number of servers that can go missing and the ensemble still run?
- A . 3
- B . 4
- C . 2
- D . 1
If I want to send binary data through the REST proxy, it needs to be base64 encoded .
Which component needs to encode the binary data into base 64?
- A . The Producer
- B . The Kafka Broker
- C . Zookeeper
- D . The REST Proxy
Latest CCDAK Dumps Valid Version with 150 Q&As
Latest And Valid Q&A | Instant Download | Once Fail, Full Refund
