Confluent CCDAK Confluent Certified Developer for Apache Kafka Certification Examination Online Training
Confluent CCDAK Online Training
The questions for CCDAK were last updated at Feb 16,2025.
- Exam Code: CCDAK
- Exam Name: Confluent Certified Developer for Apache Kafka Certification Examination
- Certification Provider: Confluent
- Latest update: Feb 16,2025
Which actions will trigger partition rebalance for a consumer group? (select three)
- A . Increase partitions of a topic
- B . Remove a broker from the cluster
- C . Add a new consumer to consumer group
- D . A consumer in a consumer group shuts down
Add a broker to the cluster
Which of the following setting increases the chance of batching for a Kafka Producer?
- A . Increase batch.size
- B . Increase message.max.bytes
- C . Increase the number of producer threads
- D . Increase linger.ms
What data format isn’t natively available with the Confluent REST Proxy?
- A . avro
- B . binary
- C . protobuf
- D . json
You are using JDBC source connector to copy data from 2 tables to two Kafka topics. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers .
How many tasks are launched?
- A . 6
- B . 1
- C . 2
- D . 3
To import data from external databases, I should use
- A . Confluent REST Proxy
- B . Kafka Connect Sink
- C . Kafka Streams
- D . Kafka Connect Source
What is a generic unique id that I can use for messages I receive from a consumer?
- A . topic + partition + timestamp
- B . topic + partition + offset
- C . topic + timestamp
What happens if you write the following code in your producer?
producer.send(producerRecord).get()
- A . Compression will be increased
- B . Throughput will be decreased
- C . It will force all brokers in Kafka to acknowledge the producerRecord
- D . Batching will be increased
Compaction is enabled for a topic in Kafka by setting log.cleanup.policy=compact .
What is true about log compaction?
- A . After cleanup, only one message per key is retained with the first value
- B . Each message stored in the topic is compressed
- C . Kafka automatically de-duplicates incoming messages based on key hashes
- D . After cleanup, only one message per key is retained with the latest value
Compaction changes the offset of messages
Which of these joins does not require input topics to be sharing the same number of partitions?
- A . KStream-KTable join
- B . KStream-KStream join
- C . KStream-GlobalKTable
- D . KTable-KTable join
How often is log compaction evaluated?
- A . Every time a new partition is created
- B . Every time a segment is closed
- C . Every time a message is sent to Kafka
- D . Every time a message is flushed to disk