Confluent Certified Developer for Apache Kafka Certification Examination - CCDAK Exam Questions

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

QUESTION NO: 2
(Which configuration determines the maximum number of records a consumer can poll in a single call to poll()?)

QUESTION NO: 3
This schema excerpt is an example of which schema format?
package com.mycorp.mynamespace;
message SampleRecord {
int32 Stock = 1;
double Price = 2;
string Product_Name = 3;
}

QUESTION NO: 4
(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?)

QUESTION NO: 5
(You have a Kafka consumer in production actively reading from a critical topic from which multiple other applications are consuming.
You have a new requirement to update the offset of your consumer to start reading from the beginning of the topic.
Which action would you take?)

QUESTION NO: 6
You are writing a producer application and need to ensure proper delivery. You configure the producer with acks=all.
Which two actions should you take to ensure proper error handling?
(Select two.)

QUESTION NO: 7
You have a topic with four partitions. The application reads from it using two consumers in a single consumer group.
Processing is CPU-bound, and lag is increasing.
What should you do?

QUESTION NO: 8
You use Kafka Connect with the JDBC source connector to extract data from a large database and push it into Kafka.
The database contains tens of tables, and the current connector is unable to process the data fast enough.
You add more Kafka Connect workers, but throughput doesn't improve.
What should you do next?

QUESTION NO: 9
Which tool can you use to modify the replication factor of an existing topic?

QUESTION NO: 10
(You are designing a stream pipeline to monitor the real-time location of GPS trackers, where historical location data is not required.
Each event has:
* Key: trackerId
* Value: latitude, longitude
You need to ensure that the latest location for each tracker is always retained in the Kafka topic.
Which topic configuration parameter should you set?)