Confluent Certified Developer for Apache Kafka Certification Examination Sample Questions:

1. (Which configuration is valid for deploying a JDBC Source Connector to read all rows from the orders table and write them to the dbl-orders topic?)

A) {"name": "jdbc-source","connector.class": "io.confluent.connect.jdbc.DdbcSourceConnector","tasks.
max": "1","connection.url": "jdbc:mysql://mysql:3306/dbl?user=user&useAutoAuth=true","topic.
prefix": "dbl-","table.whitelist": "orders"}
B) {"name": "jdbc-source","connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector","tasks.
max": "1","connection.url": "jdbc:mysql://mysql:3306/dbl?user=user&password=pas","topic.prefix":
"dbl-","table.whitelist": "orders"}
C) {"name": "orders-connect","connector.class": "io.confluent.connect.jdbc.DdbcSourceConnector","tasks.
max": "1","connection.url": "jdbc:mysql://mysql:3306/dbl","topic.whitelist": "orders","auto.create":
"true"}
D) {"name": "dbl-orders","connector.class": "io.confluent.connect.jdbc.DdbcSourceConnector","tasks.
max": "1","connection.url": "jdbc:mysql://mysql:3306/dbl?user=user&password=pas","topic.prefix":
"dbl-","table.blacklist": "ord*"}

2. You are building a system for a retail store selling products to customers.
Which three datasets should you model as a GlobalKTable?
(Select three.)

A) All purchases at a retail store occurring in real time
B) Customer profile information
C) Log of payment transactions
D) Inventory of products at a warehouse
E) Catalog of products

3. (An S3 source connector named s3-connector stopped running.
You use the Kafka Connect REST API to query the connector and task status.
One of the three tasks has failed.
You need to restart the connector and all currently running tasks.
Which REST request will restart the connector instance and all its tasks?)

A) POST /connectors/s3-connector/restart?includeTasks=true
B) POST /connectors/s3-connector/restart?includeTasks=true&onlyFailed=true
C) POST /connectors/s3-connector/tasks/0/restart
D) POST /connectors/s3-connector/restart

4. 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) Compression type will be stored in batch attributes.
B) By default, compression is the producer's responsibility.
C) All compressed messages will be stored in the same topic partition.
D) The message is already compressed so it will not be serialized.

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

Solutions: