Updated PDF (New 2026) Actual Confluent CCDAK Exam Questions [Q51-Q65]

问题 51
(You are configuring a source connector that writes records to an Orders topic.
You need to send some of the records to a different topic.
Which Single Message Transform (SMT) is best suited for this requirement?)

问题 52
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?

问题 53
There are five brokers in a cluster, a topic with 10 partitions and replication factor of 3, and a quota of producer_bytes_rate of 1 MB/sec has been specified for the client. What is the maximum throughput allowed for the client?

问题 54
To import data from external databases, I should use

问题 55
In Avro, removing or adding a field that has a default is a __ schema evolution

问题 56
(What are two stateless operations in the Kafka Streams API?
Select two.)

问题 57
If I want to send binary data through the REST proxy to topic “test_binary”, it needs to be base64 encoded. A consumer connecting directly into the Kafka topic

问题 58
You are working on an Orders microservice Thai is publishing messages lo an Orders topic. II is a business requirement that the Orders for a given customer are processed sequentially. Also, the Orders topic is partitioned tor scalability.
Which factors would you need to address during application development?

问题 59
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?

问题 60
Your manager would like to have topic availability over consistency. Which setting do you need to change in order to enable that?

问题 61
Which of the following setting increases the chance of batching for a Kafka Producer?

问题 62
Compaction is enabled for a topic in Kafka by setting log.cleanup.policy=compact. What is true about log compaction?

问题 63
There are 3 brokers in the cluster. You want to create a topic with a single partition that is resilient to one broker failure and one broker maintenance. What is the replication factor will you specify while creating the topic?

问题 64
What is the protocol used by Kafka clients to securely connect to the Confluent REST Proxy?

问题 65
Which statement is true about how exactly-once semantics (EOS) work in Kafka Streams?