Free Confluent CCDAK Exam Dumps Questions & Answers

You create a producer that writes messages about bank account transactions from tens of thousands of different customers into a topic.
Your consumers must process these messages with low latency and minimize consumer lag Processing takes ~6x longer than producing Transactions for each bank account must be processed in orderWhich strategy should you use?

• A.Use a unique identifier such as a universally unique identifier (UUID) as the message key.
• B.Use a combination of the bank account number and the transaction timestamp as the message key.
• C.Use the timestamp of the message's arrival as its key.
• D.Use the bank account number found in the message as the message key.

(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": "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*"}
• B.{"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"}
• 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": "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"}

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

(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?)

• A.cleanup.policy=compact
• B.min.cleanable.dirty.ratio=-1
• C.retention.ms=0
• D.retention.ms=infinite

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 provides the ability to wake up dormant brokers.
• B.It provides redundancy in making the initial connection to the Kafka cluster.
• C.It is the mechanism to distribute a topic's partitions across multiple brokers.
• D.It forces clients to enumerate every single broker in the cluster.