
[Aug-2025] CCDAK Exam Dumps - Free Demo & 365 Day Updates
Free Sales Ending Soon - Use Real CCDAK PDF Questions
To prepare for the Confluent CCDAK exam, developers can attend the Confluent Developer Training or take online courses, such as the Confluent Cloud Fundamentals for Developers course, which is available on Udemy. They can also refer to the official documentation and practice using Kafka clusters, producers, and consumers. There are also practice exams available online to help developers prepare for the certification exam.
NEW QUESTION # 24
When auto.create.topics.enable is set to true in Kafka configuration, what are the circumstances under which a Kafka broker automatically creates a topic? (select three)
- A. Consumer reads message from a topic
- B. Client alters number of partitions of a topic
- C. Producer sends message to a topic
- D. Client requests metadata for a topic
Answer: A,C,D
Explanation:
A kafka broker automatically creates a topic under the following circumstances- When a producer starts writing messages to the topic - When a consumer starts reading messages from the topic - When any client requests metadata for the topic
NEW QUESTION # 25
A consumer application needs to use an "at most once" delivery semantic.
What is the best consumer configuration lo avoid duplicate messages being read?
- A. auto.offset.reset=latest and enable.auto.commit=true
- B. auto.offset.reset=eariiest and enable.auto.commit=false
- C. auto.offset.reset-latest and enable auto commit-false
- D. auto.offset.reset=earliest and enable auto commit=true
Answer: A
NEW QUESTION # 26
You are managing the schema of data in a Kafka Topic using Schema Registry. You need to add new fields to the message schema. You need to select a compatibility type that allows you to add required fields, delete optional fields, and allows consumers to read all previous versions of the schema.
Which compatibility type is correct?
- A. FULL_TRANSITIVE
- B. FORWARD_TRANSITIVE
- C. BACKWARD
- D. FORWARD
Answer: A
NEW QUESTION # 27
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 REST Proxy
- B. The Kafka Broker
- C. The Producer
- D. Zookeeper
Answer: C
Explanation:
The REST Proxy requires to receive data over REST that is already base64 encoded, hence it is the responsibility of the producer
NEW QUESTION # 28
When using plain JSON data with Connect, you see the following error messageorg.apache.kafka.connect.errors.DataExceptionJsonDeserializer with schemas.enable requires "schema" and "payload" fields and may not contain additional fields. How will you fix the error?
- A. Set key.converter.schemas.enable and value.converter.schemas.enable to false
- B. Use Single Message Transforms to add schema and payload fields in the message
- C. Set key.converter, value.converter to JsonConverter and the schema registry url
- D. Set key.converter, value.converter to AvroConverter and the schema registry url
Answer: A
Explanation:
You will need to set the schemas.enable parameters for the converter to false for plain text with no schema.
NEW QUESTION # 29
There are 3 producers writing to a topic with 5 partitions. There are 5 consumers consuming from the topic. How many Controllers will be present in the cluster?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: C
Explanation:
There is only one controller in a cluster at all times.
NEW QUESTION # 30
Select the Kafka Streams joins that are always windowed joins.
- A. KStream-GlobalKTable
- B. KStream-KTable join
- C. KStream-KStream join
- D. KTable-KTable join
Answer: C
Explanation:
Seehttps://docs.confluent.io/current/streams/developer-guide/dsl-api.html#joining
NEW QUESTION # 31
How will you find out all the partitions where one or more of the replicas for the partition are not in-sync with the leader?
- A. kafka-topics.sh --broker-list localhost:9092 --describe --under-replicated-partitions
- B. kafka-topics.sh --zookeeper localhost:2181 --describe --under-replicated-partitions
- C. kafka-topics.sh --bootstrap-server localhost:9092 --describe --unavailable- partitions
- D. kafka-topics.sh --zookeeper localhost:2181 --describe --unavailable- partitions
Answer: B
NEW QUESTION # 32
If I supply the setting compression.type=snappy to my producer, what will happen? (select two)
- A. The Kafka brokers have to compress the data
- B. The Consumers have to de-compress the data
- C. The Consumers have to compress the data
- D. The Kafka brokers have to de-compress the data
- E. The Producers have to compress the data
Answer: B
Explanation:
Kafka transfers data with zero copy and no transformation. Any transformation (including compression) is the responsibility of clients.
NEW QUESTION # 33
Which of the following Kafka Streams operators are stateful? (select all that apply)
- A. reduce
- B. peek
- C. joining
- D. count
- E. aggregate
- F. flatmap
Answer: A,C,D,E
Explanation:
Seehttps://kafka.apache.org/20/documentation/streams/developer-guide/dsl-api.html#stateful-transformations
NEW QUESTION # 34
What happens if you write the following code in your producer? producer.send(producerRecord).get()
- A. Batching will be increased
- B. It will force all brokers in Kafka to acknowledge the producerRecord
- C. Compression will be increased
- D. Throughput will be decreased
Answer: D
Explanation:
Using Future.get() to wait for a reply from Kafka will limit throughput.
NEW QUESTION # 35
Partition leader election is done by
- A. The Kafka Broker that is the Controller
- B. Zookeeper
- C. The consumers
- D. Vote amongst the brokers
Answer: B
Explanation:
The Controller is a broker that is responsible for electing partition leaders
NEW QUESTION # 36
A consumer starts and has auto.offset.reset=none, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 10 for the topic before. Where will the consumer read from?
- A. offset 10
- B. offset 45
- C. offset 2311
- D. it will crash
Answer: D
Explanation:
auto.offset.reset=none means that the consumer will crash if the offsets it's recovering from have been deleted from Kafka, which is the case here, as 10 < 45
NEW QUESTION # 37
A topic has three replicas and you set min.insync.replicas to 2. If two out of three replicas are not available, what happens when a produce request with acks=all is sent to broker?
- A. NotEnoughReplicasException will be returned
- B. Produce request will block till one of the two unavailable partition is available again.
- C. Produce request is honored with single in-sync replica
Answer: A
Explanation:
With this configuration, a single in-sync replica becomes read-only. Produce request will receive NotEnoughReplicasException.
NEW QUESTION # 38
What's is true about Kafka brokers and clients from version 0.10.2 onwards?
- A. Clients and brokers must have the exact same version to be able to communicate
- B. A newer client can talk to a newer broker, and an older client can talk to a newer broker
- C. A newer client can talk to a newer broker, but an older client cannot talk to a newer broker
- D. A newer client can't talk to a newer broker, but an older client can talk to a newer broker
Answer: B
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 # 39
What is encoding and decoding of a message also known as?
- A. Serialization and deserialization
- B. Publish and subscribe
- C. Aggregation and deaggregation
- D. Scalability and fault tolerance
Answer: A
NEW QUESTION # 40
Which feature determines the maximum parallelism at which a Kafka Streams application can run?
- A. Configured Kafka Streams application instances
- B. Brokers in the Kafka cluster
- C. Input topics
- D. Partitions of the input topic(s)
Answer: D
NEW QUESTION # 41
How do Kafka brokers ensure great performance between the producers and consumers? (select two)
- A. It compresses the messages as it writes to the disk
- B. It buffers the messages on disk, and sends messages from the disk reads
- C. It transforms the messages into a binary format
- D. It does not transform the messages
- E. It leverages zero-copy optimisations to send data straight from the page-cache
Answer: D,E
Explanation:
Kafka transfers data with zero-copy and sends the raw bytes it receives from the producer straight to the consumer, leveraging the RAM available as page cache
NEW QUESTION # 42
......
CCDAK Dumps - Pass Your Certification Exam: https://www.itpass4sure.com/CCDAK-practice-exam.html
Latest Real Confluent CCDAK Exam Dumps Questions: https://drive.google.com/open?id=17GwBjy4ksQfnks67V_HRa_pH8OnoV_tN

