CCDAK Exam Questions

You need to consume messages from Kafka using the command-line interface (CLI). Which command should you use?

You are experiencing low throughput from a Java producer. You monitor the Kafka metrics and notice that the metrics for that producer show low I/O thread ratio and low I/O thread w...

Which configuration is valid for deploying a JDBC Source Connector to read all the rows from orders table and write it to db1-orders topic?

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

Which two statements are correct about transactions in Kafka? (Choose two.)

You are designing a stream pipeline to monitor the real-time location of GPS trackers, where historical location data is not required. Each event in the stream has the following st...

You need to collect logs from a host and write them to a Kafka topic named 'logs-topic'. You decide to use Kafka Connect File Source connector for this task. What is the preferred...

You create a topic named 'IoT-Data' with 10 partitions and replication factor of three. A producer application is producing messages with 1 mb size. The messages need to be compres...

The producer code below features a 'Callback' class with a method called 'onCompletion()'. When will the 'onCompletion()' method be invoked?

What is the purpose of the key.serializer property?

You are working on an Orders microservice that is publishing messages to an Orders topic. It is a business requirement that the Orders for a given customer are processed sequential...

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

Your company has three Kafka clusters: Development, Testing, and Production. The Production cluster is running out of storage so you add a new node to the Kafka cluster. Which two...

You are receiving messages in your consumer slower than you expect. Which command can you use to determine whether there is any consumer lag?

You need to list the topics that are available in your Kafka cluster. Which command should you use?

You create a topic named 'stream-logs'. The topic has: - A replication factor of three - Four partitions - Messages that are plain logs without a key How will messages be distribut...

A stream processing application is tracking user activity of online shopping carts. The application tracks items added to the cart, items removed from the cart, and items ordered f...

You want to connect with username and password to a secured Kafka cluster that has SSL encryption. Which properties must your client include?

This schema excerpt is an example of which schema format?

You want to enrich the content of a topic. You need to join the topic with the key records from a second topic. These two topics each have a different number of partitions. Which t...

Your configuration parameters for a Source connector and Connect worker are: - offset.flush.interval.ms=60000 - offset.flush.timeout.ms=500 - offset.storage.topic=connect-offsets -...

Which statement is true about how exactly-once semantics (EOS) work in Kafka Streams?

Which property must be set at the producer end to prepare the producer for transactions?

Which tool can you use to modify the replication factor of an existing topic?

You are composing a REST request to create a new connector in a running Connect cluster. You invoke POST /connectors with a configuration and receive a 409 (Conflict) response. Wha...

A stream processing application is consuming from a topic with five partitions. You run three instances of the application. Each instance has num.streams.threads set to five. You n...

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

Your Kafka cluster has five brokers. The topic t1 on the cluster has: - Two partitions - Replication.factor = 4 - min.insync.replicas = 3 You need strong durability guarantees for...

Which configuration allows more time for the consumer poll to process records?

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

A producer is configured with the default partitioner. It is sending records to a topic that is configured with five partitions. The record does not contain any key. What is the re...

Which two producer exceptions are examples of the class RetriableException? (Choose two.)

Which partition assignment minimizes partition movements between two assignments?

Which is true about topic compaction?

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

You are sending messages to a Kafka cluster in JSON format and want to add more information related to each message. The information needed is: - Format of the message payload - Me...

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

Kafka producers can batch messages going to the same partition. Which statement is correct about producer batching?

What is the default maximum size of a message the Apache Kafka broker can accept?

You have a topic t1 with six partitions. You use Kafka Connect to send data from topic t1 in your Kafka cluster to Amazon S3. Kafka Connect is configured for two tasks. How many pa...

This schema excerpt is an example of which schema format?

You have a consumer group with default configuration settings reading messages from your Kafka cluster. You need to optimize throughput so the consumer group processes more message...

You are writing a producer application and need to ensure proper delivery. You configure the producer with acks level to all. Which two actions should you take to ensure proper err...

What are three built-in abstractions in the Kafka Streams DSL? (Choose two.)

Which two statements about Kafka Connect single message transforms (SMT) are correct? (Choose two.)

Which statement describes the storage location for a sink connectors offsets?

Where are source connector offsets stored?

What is accomplished by producing data to a topic with a message key?

You need to configure a sink connector to write records that fail into a dead letter queue topic. Requirements: - Topic name: 'DLQ-Topic' - Headers containing error context need to...

You are developing a Java application including a Kafka consumer. - You need to integrate the Kafka's client logs with your own application's log - Your application is using log4j2...