Confluent Certified Developer for Apache Kafka Certification Examination (CCDAK) Free Practice Test

Question 1

Which configuration determines how many bytes of data are collected before sending messages to the Kafka broker?

A. send.buffer.bytes

B. buffer.memory

C. max.block.size

D. batch.size

Correct Answer: D

Explanation: Only visible for TestSimulate members. You can sign-up / login (it's free).

Question 2

(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 subscribe() method with an empty consumer group name configuration.

B. Use the subscribe() method with a regular expression argument.

C. Use the assign() method using all topic-partitions of the topic as argument.

D. Use the assign() method with the topic name as argument.

Correct Answer: C

Explanation: Only visible for TestSimulate members. You can sign-up / login (it's free).

Question 3

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

Question 4

(Your application consumes from a topic configured with a deserializer.
You want the application to be resilient to badly formatted records (poison pills).
You surround the poll() call with a try/catch block for RecordDeserializationException.
You need to log the bad record, skip it, and continue processing other records.
Which action should you take in the catch block?)

A. Log the bad record and seek the consumer to the offset of the next record.

B. Log the bad record and call consumer.skip() method.

C. Log the bad record; no other action is needed.

D. Throw a runtime exception to trigger a restart of the application.

Correct Answer: A

Explanation: Only visible for TestSimulate members. You can sign-up / login (it's free).

Question 5

Which two statements are correct when assigning partitions to the consumers in a consumer group using the assign() API?
(Select two.)

A. It is mandatory to subscribe to a topic before calling assign() to assign partitions.

B. The consumer chooses which partition to read without any assignment from brokers.

C. All topics must have the same number of partitions to use assign() API.

D. The consumer group will not be rebalanced if a consumer leaves the group.

Correct Answer: B,D

Explanation: Only visible for TestSimulate members. You can sign-up / login (it's free).

Question 6

(You need to set alerts on key broker metrics to trigger notifications when a Kafka cluster is unhealthy.
What are three minimum broker metrics to monitor for cluster health?
Select three.)

A. kafka.controller:type=ControllerStats,name=UncleanLeaderElectionsPerSec

B. kafka.controller:type=KafkaController,name=LastCommittedRecordOffset

C. kafka.controller:type=KafkaController,name=TopicsToDeleteCount

D. kafka.controller:type=KafkaController,name=OfflinePartitionsCount

E. kafka.controller:type=KafkaController,name=ActiveControllerCount

Correct Answer: A,D,E

Explanation: Only visible for TestSimulate members. You can sign-up / login (it's free).

Question 7

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

A. Kafka Streams disables log compaction on internal changelog topics to preserve all state changes for potential recovery.

B. EOS in Kafka Streams relies on transactional producers to atomically commit state updates to changelog topics and output records to Kafka.

C. Kafka Streams provides EOS by periodically checkpointing state stores and replaying changelogs to recover only unprocessed messages during failure.

D. EOS in Kafka Streams is implemented by creating a separate Kafka topic for deduplication of all messages processed by the application.

Correct Answer: B

Explanation: Only visible for TestSimulate members. You can sign-up / login (it's free).

Question 8

(You have a Kafka Connect cluster with multiple connectors deployed.
One connector is not working as expected.
You need to find logs related to that specific connector to investigate the issue.
How can you find the connector's logs?)

A. Change the log level to DEBUG to include connector context information.

B. Modify the log4j.properties file to add a dedicated log appender for the connector.

C. Make no change; there is no way to isolate connector logs.

D. Modify the log4j.properties file to enable connector context.

Correct Answer: B

Explanation: Only visible for TestSimulate members. You can sign-up / login (it's free).

Question 9

Clients that connect to a Kafka cluster are required to specify one or more brokers in the bootstrap.servers parameter.
What is the primary advantage of specifying more than one broker?

A. It is the mechanism to distribute a topic's partitions across multiple brokers.

B. It provides the ability to wake up dormant brokers.

C. It provides redundancy in making the initial connection to the Kafka cluster.

D. It forces clients to enumerate every single broker in the cluster.

Correct Answer: C

Explanation: Only visible for TestSimulate members. You can sign-up / login (it's free).

Question 10

Which two statements about Kafka Connect Single Message Transforms (SMTs) are correct?
(Select two.)

A. Multiple SMTs can be chained together and act on source or sink messages.

B. SMT functionality is included within Kafka Connect converters.

C. SMTs are often used to join multiple records from a source data system into a single Kafka record.

D. Masking data is a good example of an SMT.

Correct Answer: A,D

Explanation: Only visible for TestSimulate members. You can sign-up / login (it's free).

Welcome to TestSimulate

Confluent Certified Developer for Apache Kafka Certification Examination (CCDAK) Free Practice Test