Confluent Certified Developer for Apache Kafka Certification Examination - CCDAK FREE EXAM DUMPS QUESTIONS & ANSWERS]

Question 1

You create a topic named loT-Data with 10 partitions and replication factor of three.
A producer sends 1 MB messages compressed with Gzip.
Which two statements are true in this scenario?
(Select two.)

A. All compressed messages will be stored in the same topic partition. B. By default, compression is the producer's responsibility. C. The message is already compressed so it will not be serialized. D. Compression type will be stored in batch attributes.

Discussion 0

Correct Answer: B,D Vote an answer

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

Question 2

Your application is consuming from a topic with one consumer group.
The number of running consumers is equal to the number of partitions.
Application logs show that some consumers are leaving the consumer group during peak time, triggering a rebalance. You also notice that your application is processing many duplicates.
You need to stop consumers from leaving the consumer group.
What should you do?

A. Split consumers in different consumer groups. B. Increase session.timeout.ms property. C. Add more consumer instances. D. Reduce max.poll.records property.

Discussion 0

Correct Answer: B Vote an answer

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

Question 3

(You are developing a Kafka Streams application with a complex topology that has multiple sources, processors, sinks, and sub-topologies.
You are working in a development environment and do not have access to a real Kafka cluster or topics.
You need to perform unit testing on your Kafka Streams application.
Which should you use?)

A. TopologyTestDriver B. TestProducer, TestConsumer C. KafkaUnitTestDriver D. MockProducer, MockConsumer

Discussion 0

Correct Answer: A Vote an answer

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

Question 4

(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=KafkaController,name=LastCommittedRecordOffset B. kafka.controller:type=ControllerStats,name=UncleanLeaderElectionsPerSec C. kafka.controller:type=KafkaController,name=TopicsToDeleteCount D. kafka.controller:type=KafkaController,name=OfflinePartitionsCount E. kafka.controller:type=KafkaController,name=ActiveControllerCount

Discussion 0

Correct Answer: B,D,E Vote an answer

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

Question 5

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

A. send.buffer.bytes B. max.block.size C. batch.size D. buffer.memory

Discussion 0

Correct Answer: C Vote an answer

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

Question 6

(You have a topic with four partitions. The application reading this topic is using a consumer group with two consumers.
Throughput is smoothly distributed among partitions, but application lag is increasing.
Application monitoring shows that message processing is consuming all available CPU resources.
Which action should you take to resolve this issue?)

A. Increase the max.poll.records property of consumers. B. Decrease the max.poll.records property of consumers. C. Add more consumers to increase the level of parallelism of the processing. D. Add more partitions to the topic to increase the level of parallelism of the processing.

Discussion 0

Correct Answer: C Vote an answer

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

Question 7

Match each configuration parameter with the correct deployment step in installing a Kafka connector.

Discussion 0

Correct Answer:

Explanation:
1st: Place the connector's JAR file in the directory specified by plugin.path
2nd: Restart the Kafka Connect cluster
3rd: Verify using REST API (/connector-plugins)
4th: Configure the connector
5th: (Repeat of 4th, duplicate step)
1st # Place the connector's JAR file in the directory specified by the plugin.path configuration.
2nd # Restart the Kafka Connect cluster.
3rd # Verify that the connector is installed by listing all available connectors using the Kafka Connect REST API (/connector-plugins).
4th # Configure the connector using a JSON or properties file with the necessary settings.
5th # Configure the connector using a JSON or properties file with the necessary settings.
Kafka Connect requires that custom connectors be placed in the directory defined by plugin.path. After restarting the cluster, you can use the REST API to confirm availability and then deploy the connector configuration.
From Kafka Connect Documentation:
"After placing the JAR in the plugin.path, you must restart the Connect cluster to pick it up. Use the
/connector-plugins REST endpoint to verify."
The duplication of configuration is an error in the question options and should occur only once.
Reference: Kafka Connect Plugin Installation Guide

Question 8

(A consumer application runs once every two weeks 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=latest.
The current offsets in the topic start at 318 and end at 588.
Which offset will the application start reading from when it starts up for its next run?)

A. 589 B. 318 C. 218 D. 0

Discussion 0

Correct Answer: A Vote an answer

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

Question 9

(You create a topic with five partitions.
What can you assume about messages read from that topic by a single consumer group?)

A. Messages from one partition can be consumed by any of the consumers in a group for faster processing. B. The consumer group can only read the same number of messages from all the partitions. C. Messages can be consumed by a maximum of five consumers in the same consumer group. D. All messages will be read from exactly one broker by the consumer group.

Discussion 0

Correct Answer: C Vote an answer

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

Question 10

An application is consuming messages from Kafka.
The application logs show that partitions are frequently being reassigned within the consumer group.
Which two factors may be contributing to this?
(Select two.)

A. There is a storage issue on the broker. B. There is a slow consumer processing application. C. The number of partitions does not match the number of application instances. D. An instance of the application is crashing and being restarted.

Discussion 0

Correct Answer: B,D Vote an answer

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