[2025] CCDAK All-in-One Exam Guide Practice To your CCDAK Exam!
Preparations of CCDAK Exam 2025 Confluent Certified Developer Unlimited 260 Questions
The CCDAK 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 clusters and applications. Confluent Certified Developer for Apache Kafka Certification Examination certification is valid for two years, and developers are required to renew their certification by passing a recertification exam.
NEW QUESTION # 82
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. 0
- B. 1
- C. 2
- D. 3
- E. 4
- F. 5
Answer: B,D,F
Explanation:
2181 - client port, 2888 - peer port, 3888 - leader port
NEW QUESTION # 83
Which of the following is a push query?
- A. SELECT *
FROM NUMBER_OF_TESTS
WHERE ID='10'; - B. CREATE TABLE LEFT_TABLE (ID BIGINT PRIMARY KEY, NAME varchar, VALUE bigint) WITH (kafka_topic='left_topic', value_format='JSON', partitions=4);
- C. CREATE STREAM STUDENTS (ID STRING KEY, SCORE INT)
WITH (kafka_topic='students_topic', value_format='JSON', partitions=4); - D. SELECT windowstart, windowend, item_id, SUM(quantity)
FROM orders
WINDOW TUMBLING (SIZE 20 SECONDS)
GROUP BY item_id
EMIT CHANGES;
Answer: D
NEW QUESTION # 84
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 643
- C. offset 2311
- D. offset 45
Answer: B
Explanation:
The offsets are already committed for this consumer group and topic partition, so the property auto.offset.reset is ignored
NEW QUESTION # 85
Using the Confluent Schema Registry, where are Avro schema stored?
- A. In the Zookeeper node /schemas
- B. In the _schemas topic
- C. In the Schema Registry embedded SQL database
- D. In the message bytes themselves
Answer: B
Explanation:
The Schema Registry stores all the schemas in the _schemas Kafka topic
NEW QUESTION # 86
What are three built-in abstractions in the Kafka Streams DSL?
(Select three.)
- A. GlobalKTable
- B. KStream
- C. GlobalKStream
- D. KTable
- E. StreamTable
Answer: A,B,D
Explanation:
TheKafka Streams DSLprovides three primary abstractions:
* KStream: Represents an unbounded stream of records (append-only).
* KTable: Represents a changelog stream where each key has the latest value (like a materialized view).
* GlobalKTable: A fully replicated version of KTable across all stream instances, enabling global joins.
FromKafka Streams Developer Guide:
"Kafka Streams provides three core abstractions: KStream, KTable, and GlobalKTable, each serving different purposes in stream processing and joins."
* GlobalKStream and StreamTable donot existin Kafka's API.
Reference:Kafka Streams Concepts > KStream, KTable, GlobalKTable
NEW QUESTION # 87
Which configuration allows more time for the consumer poll to process records?
- A. max.poll.interval.ms
- B. heartbeat.interval.ms
- C. session.timeout.ms
- D. fetch.max.wait.ms
Answer: A
Explanation:
max.poll.interval.ms defines themaximum delay between invocations of poll()before the consumer is considered failed. It essentially gives consumers more time to process records before needing to poll again.
FromKafka Consumer Configuration Reference:
"max.poll.interval.ms: The maximum delay between invocations of poll() when using consumer group management. If poll() is not called before expiration, the consumer is considered failed."
* session.timeout.ms and heartbeat.interval.ms relate to group coordination and heartbeats.
* fetch.max.wait.ms affects how long the broker waits to accumulate data before sending a fetch response.
Reference:Apache Kafka Consumer Configs
NEW QUESTION # 88
Which Kafka CLI should you use to consume from a topic?
- A. kafka-topics
- B. kafka-console
- C. kafka-console-consumer
- D. kafka-consumer-groups
Answer: C
Explanation:
Examplekafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning
NEW QUESTION # 89
Where are source connector offsets stored?
- A. offset, storage, partitions
- B. storage.offset.topic
- C. offset.storage.topic
- D. topic.offset.config
Answer: C
Explanation:
Kafka Connectsource connectorsuse theoffset.storage.topicconfiguration parameter to define where to store offsets that track the connector's positionin the source system (e.g., database, file, etc.).
FromKafka Connect Worker Configuration:
"offset.storage.topic specifies the topic in Kafka where the connector stores offsets for each source partition." This allows Kafka Connect toresumefrom the correct position on restart.
* The other options (B-D) are not valid Kafka configs.
Reference:Kafka Connect Worker Configs > offset.storage.topic
NEW QUESTION # 90
You have a Kafka client application that has real-time processing requirements.
What are the most important metrics available in Kafka that you should monitor?
- A. Total time to serve requests to replica followers
- B. Aggregate incoming byte rate
- C. Consumer heartbeat rate to the group coordinator
- D. Consumer lag between the brokers and the consumers
Answer: D
NEW QUESTION # 91
Consumer failed to process record # 10 and succeeded in processing record # 11. Select the course of action that you should choose to guarantee at least once processing
- A. Do not commit until successfully processing the record #10
- B. Commit offsets at 10
- C. Commit offsets at 11
Answer: C
Explanation:
Here, you shouldn't commit offsets 11 or 10 as it would indicate that the message #10 has been processed successfully.
NEW QUESTION # 92
What are the requirements for a Kafka broker to connect to a Zookeeper ensemble? (select two)
- A. Unique values for each broker's broker.id parameter
- B. All the brokers must share the same broker.id
- C. All the brokers must share the same zookeeper.connect parameter
- D. Unique value for each broker's zookeeper.connect parameter
Answer: A,C
Explanation:
Each broker must have a unique broker id and connect to the same zk ensemble and root zNode
NEW QUESTION # 93
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: A,F
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 # 94
In Avro, adding an element to an enum without a default is a __ schema evolution
- A. breaking
- B. forward
- C. backward
- D. full
Answer: A
Explanation:
Since Confluent 5.4.0, Avro 1.9.1 is used. Since default value was added to enum complex type , the schema resolution changed from:
(<1.9.1) if both are enums:** if the writer's symbol is not present in the reader's enum, then an error is signalled. **(>=1.9.1) if both are enums:
if the writer's symbol is not present in the reader's enum and the reader has a default value, then that value is used, otherwise an error is signalled.
NEW QUESTION # 95
What is the risk of increasing max.in.flight.requests.per.connection while also enabling retries in a producer?
- A. At least once delivery is not guaranteed
- B. Reduce throughput
- C. Message order not preserved
- D. Less resilient
Answer: C
Explanation:
Some messages may require multiple retries. If there are more than 1 requests in flight, it may result in messages received out of order. Note an exception to this rule is if you enable the producer settingenable.
idempotence=true which takes care of the out of ordering case on its own. Seehttps://issues.apache.org/jira
/browse/KAFKA-5494
NEW QUESTION # 96
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 num.partitions=#of brokers and replication.factor=3
- 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 1 partition and 1 replication factor
Answer: C
Explanation:
The broker settings comes into play when a topic is auto created
NEW QUESTION # 97
To enhance compression, I can increase the chances of batching by using
- A. acks=all
- B. linger.ms=20
- C. max.message.size=10MB
- D. batch.size=65536
Answer: B
Explanation:
linger.ms forces the producer to wait before sending messages, hence increasing the chance of creating batches that can be heavily compressed.
NEW QUESTION # 98
Which feature determines the maximum parallelism at which a Kafka Streams application can run?
- A. Configured Kafka Streams application instances
- B. Input topics
- C. Brokers in the Kafka cluster
- D. Partitions of the input topic(s)
Answer: D
NEW QUESTION # 99
You want to perform table lookups against a KTable everytime a new record is received from the KStream.
What is the output of KStream-KTable join?
- A. GlobalKTable
- B. KTable
- C. You choose between KStream or KTable
- D. Kstream
Answer: D
Explanation:
Here KStream is being processed to create another KStream.
NEW QUESTION # 100
......
Focus on CCDAK All-in-One Exam Guide For Quick Preparation: https://prepaway.updatedumps.com/Confluent/CCDAK-updated-exam-dumps.html