We're so confident of our products that we provide no hassle product exchange.
Confluent CCDAK Exam Overview:
| Certification Vendor: | Confluent |
|---|---|
| Exam Name: | Confluent Certified Developer for Apache Kafka (CCDAK) Certification Exam |
| Exam Number: | CCDAK |
| Exam Duration: | 90 minutes |
| Exam Price: | $150 USD |
| Exam Format: | Multiple select, Multiple choice |
| Related Certifications: | Confluent Certified Developer for Apache Kafka (CCDAK) Confluent Certified Administrator for Apache Kafka (CCAK) |
| Passing Score: | 70% |
| Certificate Validity Period: | 3 years |
| Real Exam Qty: | 60 |
| Available Languages: | English |
| Recommended Training: | Kafka Fundamentals Course Apache Kafka Developer Training (Confluent) |
| Exam Registration: | Confluent Certification Portal Confluent Training and Exams |
| Sample Questions: | Confluent CCDAK Sample Questions |
| Exam Way: | Online proctored exam or authorized testing center |
| Pre Condition: | Basic understanding of Java or another JVM language and familiarity with distributed systems concepts is recommended. |
| Official Syllabus URL: | https://www.confluent.io/certification/ |
Confluent CCDAK Exam Syllabus Topics:
| Section | Objectives |
|---|---|
| Topic 1: Kafka Producers and Consumers | - Consumer API
|
| Topic 2: Kafka Ecosystem and Confluent Platform | - ksqlDB and connectors
|
| Topic 3: Kafka Streams and Processing | - Event processing patterns
|
| Topic 4: Kafka Fundamentals | - Data flow in Kafka
|
Confluent Certified Developer for Apache Kafka Certification Examination Sample Questions:
You are developing a Java application using a Kafka consumer.
You need to integrate Kafka's client logs with your own application's logs using log4j2.
Which Java library dependency must you include in your project?
- A. Just the log4j2 dependency of the application
- B. None, the right dependency will be added by the Kafka client dependency by transitivity.
- C. SLF4J implementation for Log4j 1.2 (org.slf4j:slf4j-log4j12)
- D. SLF4J implementation for Log4j2 (org.apache.logging.log4j:log4j-slf4j-impl)
Correct Answer: D 🗳️
Explanation: Only visible for BraindumpQuiz members. You can sign-up / login (it's free).
Match the topic configuration setting with the reason the setting affects topic durability.
(You are given settings like unclean.leader.election.enable=false, replication.factor, min.insync.replicas=2)
Correct Answer:
Explanation:
unclean.leader.election.enable=false # Prevents data loss by only considering in-sync replicas when rebalancing.
replication.factor # Specifies how many redundant copies of partitions are distributed across brokers.
min.insync.replicas=2 # Sets the standard for the number of partition instances that must keep up with the latest committed message.
unclean.leader.election.enable=false ensures that only in-sync replicas can be elected as leaders. If disabled, an out-of-sync replica may become leader, potentially leading to data loss.
replication.factor defines how many brokers will maintain copies of each partition, directly impacting durability and availability.
min.insync.replicas determines how many replicas must acknowledge a write when acks=all is used, enforcing write durability.
Reference: Apache Kafka Topic Configuration Documentation
A stream processing application is consuming from a topic with five partitions. You run three instances of the application. Each instance has num.stream.threads=5.
You need to identify the number of stream tasks that will be created and how many will actively consume messages from the input topic.
- A. 15 created, 5 actively consuming
- B. 15 created, 15 actively consuming
- C. 5 created, 5 actively consuming
- D. 5 created, 1 actively consuming
Correct Answer: B 🗳️
Explanation: Only visible for BraindumpQuiz members. You can sign-up / login (it's free).
(You want to read messages from all partitions of a topic in every consumer instance of your application.
How do you do this?)
- A. Use the assign() method with the topic name as argument.
- B. Use the subscribe() method with a regular expression argument.
- C. Use the subscribe() method with an empty consumer group name configuration.
- D. Use the assign() method using all topic-partitions of the topic as argument.
Correct Answer: D 🗳️
Explanation: Only visible for BraindumpQuiz members. You can sign-up / login (it's free).
(What are two stateless operations in the Kafka Streams API?
Select two.)
- A. Filter
- B. Reduce
- C. GroupBy
- D. Join
Correct Answer: A,C 🗳️
Explanation: Only visible for BraindumpQuiz members. You can sign-up / login (it's free).
By Hilary
