CCDAK Exam Questions

You need to correctly join data from two Kafka topics. Which two scenarios will allow for the co- partitioning? (Choose two.)

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 contr...

You have a Kafka client application that has real-time processing requirements. Which Kafka metric should you monitor?

What is a consequence of increasing the number of partitions in an existing Kafka topic?

You need to set alerts on key broker metrics to trigger notifications in the event that a cluster is unhealthy. What are three minimum broker metrics to monitor for cluster health?...

The producer code below features a 'Callback' class with a method called 'onCompletion()'. In the 'onCompletion()' method, when the request is completed successfully, what does the...

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

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 i...

You need to explain the best reason to implement the consumer callback interface 'ConsumerRebalanceListener' prior to a Consumer Group Rebalance. Which statement is correct?

Your application is consuming from a topic configured with a deserializer. The application needs to be resilient to badly formatted records (poison pills) so you surround the 'poll...

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

You have a topic with four partitions. The application reading this topic is using a consumer group and two consumers. The throughput is smoothly distributed among partitions but t...

You have a 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...

You are writing to a topic with producer config acks=all. The producer is receiving acknowledgements from the Kafka broker indicating that messages are being written to the Kafka t...

You are working on a Kafka cluster with three nodes. You create a Kafka topic named orders on this cluster with: - replication factor=3 - min.insync.replicas=2 - acks=all Which exc...

What are two examples of performance metrics? (Choose two.)