Online Access Free CCDAK Practice Test

You are sending messages to a Kafka cluster in JSON format and want to add more information related to each message:
Format of the message payload
Message creation time
A globally unique identifier that allows the message to be traced through the systemWhere should this additional information be set?

• A.Header
• B.Value
• C.Broker
• D.Key

(Your application consumes from a topic configured with a deserializer.
You want the application to be resilient to badly formatted records (poison pills).
You surround the poll() call with a try/catch block for RecordDeserializationException.
You need to log the bad record, skip it, and continue processing other records.
Which action should you take in the catch block?)

• A.Log the bad record; no other action is needed.
• B.Throw a runtime exception to trigger a restart of the application.
• C.Log the bad record and call consumer.skip() method.
• D.Log the bad record and seek the consumer to the offset of the next record.

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;
}

• A.Avro
• B.JSON Schema
• C.Protobuf
• D.YAML

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 deployment mode for this connector?

• A.Distributed mode
• B.Standalone mode
• C.SingleCluster mode
• D.Parallel mode

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

• A.Masking data is a good example of an SMT.
• B.SMTs are often used to join multiple records from a source data system into a single Kafka record.
• C.SMT functionality is included within Kafka Connect converters.
• D.Multiple SMTs can be chained together and act on source or sink messages.