Regular Free Updates CCDAK Dumps Real Exam Questions Test Engine Sep 03, 2025
Practice Test Questions Verified Answers As Experienced in the Actual Test!
The CCDAK certification exam is a globally recognized certification for Kafka developers, offered by Confluent. CCDAK exam is designed to test developers' knowledge and skills in building and managing Kafka clusters and writing efficient Kafka applications. Confluent Certified Developer for Apache Kafka Certification Examination certification is ideal for developers who want to demonstrate their expertise in Apache Kafka and advance their careers in this field. Confluent Certified Developer for Apache Kafka Certification Examination certification is also beneficial for organizations that use Kafka in their infrastructure, as it ensures that their developers have the necessary skills to build and manage Kafka applications.
NEW QUESTION # 84
A consumer application runs once a week and reads from a Kafka topic. The last time the application ran, the last offset processed was 217. The application is configured with auto.offset.reset set to "latest". The current offsets in the topic start at 318 and end at 588.
What offset will the application start reading when it starts up for its next run?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: B
NEW QUESTION # 85
Kafka is configured with following parameters - log.retention.hours = 168 log.retention.minutes = 168 log.
retention.ms = 168 How long will the messages be retained for?
- A. 168 minutes
- B. Broker will not start due to bad configuration
- C. 168 ms
- D. 168 hours
Answer: C
Explanation:
If more than one similar config is specified, the smaller unit size will take precedence.
NEW QUESTION # 86
You are writing to a topic with acks=all.
The producer receives acknowledgments but you notice duplicate messages.
You find that timeouts due to network delay are causing resends.
Which configuration should you use to prevent duplicates?
- A. retries=0
max.in.flight.requests.per.connection=5
enable.idempotence=true - B. retries=2147483647
max.in.flight.requests.per.connection=1
enable.idempotence=false - C. retries=2147483647
max.in.flight.requests.per.connection=5
enable.idempotence=true - D. enable.auto.commit=true
Answer: C
Explanation:
To ensureexactly-once deliveryand avoid duplicates even during retries:
* enable.idempotence=trueensures deduplication on the broker
* retries=2147483647allows unlimited retries on retriable errors
* max.in.flight.requests.per.connection=5is themaximum value that preserves message order with idempotence FromKafka Producer Config Docs:
"To achieve exactly-once semantics, set enable.idempotence=true, and max.in.flight.requests.per.connection #
5."
* A is unrelated (consumer-side)
* C disables retries
* D disables idempotence, leading to duplicates
Reference:Kafka Producer Configs > enable.idempotence, retries
NEW QUESTION # 87
What data format isn't natively available with the Confluent REST Proxy?
- A. binary
- B. json
- C. protobuf
- D. avro
Answer: C
Explanation:
Protocol buffers isn't a natively supported type for the Confluent REST Proxy, but you may use the binary format instead
NEW QUESTION # 88
In Avro, removing or adding a field that has a default is a __ schema evolution
- A. forward
- B. backward
- C. full
- D. breaking
Answer: C
Explanation:
Clients with new schema will be able to read records saved with old schema and clients with old schema will be able to read records saved with new schema.
NEW QUESTION # 89
You create a producer that writes messages about bank account transactions from tens of thousands of different customers into a topic.
* Your consumers must process these messages with low latency and minimize consumer lag
* Processing takes ~6x longer than producing
* Transactions for each bank account must be processedin orderWhich strategy should you use?
- A. Use the timestamp of the message's arrival as its key.
- B. Use a unique identifier such as a universally unique identifier (UUID) as the message key.
- C. Use a combination of the bank account number and the transaction timestamp as the message key.
- D. Use the bank account number found in the message as the message key.
Answer: D
Explanation:
To maintainmessage ordering per bank account, themessage key must be the account number. Kafka guaranteesordering per partition, and the partition is selected based on thehash of the key.
FromKafka Producer Docs:
"All records with the same key will be sent to the same partition, and Kafka preserves the order of records in a partition." Using account number ensures:
* All messages for the same account go to the same partition
* Order is maintained
* Workload is evenly distributed if account keys are varied
Other options break ordering or introduce unnecessary randomness.
Reference:Kafka Producer Concepts > Partitions and Keys
NEW QUESTION # 90
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. 0
- B. 1
- C. 2
- D. 3
- E. 4
- F. 5
Answer: B,C
Explanation:
When you create a new topic, partitions replicas are spreads across racks to maintain availability. Hence, the Rack A, which currently does not hold the topic partition, will be selected for the last replica
NEW QUESTION # 91
Which of the following is NOT a supported serialization format in ksqlDB?
- A. Protobuf
- B. Delimited
- C. Avro
- D. BSON
Answer: D
NEW QUESTION # 92
We would like to be in an at-most once consuming scenario. Which offset commit strategy would you recommend?
- A. Do not commit any offsets and read from beginning
- B. Commit the offsets in Kafka, after processing the data
- C. Commit the offsets in Kafka, before processing the data
- D. Commit the offsets on disk, after processing the data
Answer: C
Explanation:
Here, we must commit the offsets right after receiving a batch from a call to .poll()
NEW QUESTION # 93
Select all the way for one consumer to subscribe simultaneously to the following topics - topic.history, topic.
sports, topic.politics? (select two)
- A. consumer.subscribe(Pattern.compile("topic\..*"));
- B. consumer.subscribe(Arrays.asList("topic.history", "topic.sports", "topic.politics"));
- C. consumer.subscribe("topic.history"); consumer.subscribe("topic.sports"); consumer.subscribe("topic.
politics"); - D. consumer.subscribePrefix("topic.");
Answer: A,B
Explanation:
Multiple topics can be passed as a list or regex pattern.
NEW QUESTION # 94
A consumer has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to
2311. The consumer group never committed offsets for the topic before. Where will the consumer read from?
- A. it will crash
- B. offset 0
- C. offset 45
- D. offset 2311
Answer: D
Explanation:
Latest means that data retrievals will start from where the offsets currently end
NEW QUESTION # 95
Which of the following errors are retriable from a producer perspective? (select two)
- A. INVALID_REQUIRED_ACKS
- B. TOPIC_AUTHORIZATION_FAILED
- C. MESSAGE_TOO_LARGE
- D. NOT_ENOUGH_REPLICAS
- E. NOT_LEADER_FOR_PARTITION
Answer: D,E
Explanation:
Both of these are retriable errors, others non-retriable errors. See the full list of errors and their "retriable" status herehttps://kafka.apache.org/protocol#protocol_error_codes
NEW QUESTION # 96
What's is true about Kafka brokers and clients from version 0.10.2 onwards?
- A. A newer client can talk to a newer broker, and an older client can talk to a newer broker
- B. A newer client can talk to a newer broker, but an older client cannot talk to a newer broker
- C. A newer client can't talk to a newer broker, but an older client can talk to a newer broker
- D. Clients and brokers must have the exact same version to be able to communicate
Answer: A
Explanation:
Kafka's new bidirectional client compatibility introduced in 0.10.2 allows this. Read more herehttps://www.
confluent.io/blog/upgrading-apache-kafka-clients-just-got-easier/
NEW QUESTION # 97
You are using JDBC source connector to copy data from 3 tables to three 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. 0
- B. 1
- C. 2
- D. 3
Answer: D
Explanation:
here, we have three tables, but the max.tasks is 2, so that's the maximum number of tasks that will be created
NEW QUESTION # 98
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. 0
- B. 1
- C. 2
- D. 3
Answer: D
Explanation:
we have two tables, so the max number of tasks is 2
NEW QUESTION # 99
is KSQL ANSI SQL compliant?
- A. Yes
- B. No
Answer: B
Explanation:
KSQL is not ANSI SQL compliant, for now there are no defined standards on streaming SQL languages
NEW QUESTION # 100
Which configurations define which connector is deployed?
- A. value.converter
- B. rest. extension. classes
- C. connector.class
- D. key. converter
Answer: C
NEW QUESTION # 101
In Kafka, every broker... (select three)
- A. is a bootstrap broker
- B. is a controller
- C. contains only a subset of the topics and the partitions
- D. knows all the metadata for all topics and partitions
- E. knows the metadata for the topics and partitions it has on its disk
- F. contains all the topics and all the partitions
Answer: A,C,D
Explanation:
Kafka topics are divided into partitions and spread across brokers. Each brokers knows about all the metadata and each broker is a bootstrap broker, but only one of them is elected controller
NEW QUESTION # 102
Match the testing tool with the type of test it is typically used to perform.
Answer:
Explanation:
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 forreal environment testing.
* Trogdor: Kafka's built-inperformance load testingframework.
* Connect Datagen: Createssample source recordsfor test and demo purposes.
FromKafka 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
NEW QUESTION # 103
A bank uses a Kafka cluster for credit card payments. What should be the value of the property unclean.leader.
election.enable?
- A. FALSE
- B. TRUE
Answer: A
Explanation:
Setting unclean.leader.election.enable to true means we allow out-of-sync replicas to become leaders, we will lose messages when this occurs, effectively losing credit card payments and making our customers very angry.
NEW QUESTION # 104
To get acknowledgement of writes to only the leader partition, we need to use the config...
- A. acks=all
- B. acks=1
- C. acks=0
Answer: B
Explanation:
Producers can set acks=1 to get acknowledgement from partition leader only.
NEW QUESTION # 105
......
Pass Confluent CCDAK Exam in First Attempt Easily: https://testinsides.vcedumps.com/CCDAK-examcollection.html
