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 combination of the bank account number and the transaction timestamp as the message key.
• B.  Use the timestamp of the message's arrival as its key.
• C.  Use the bank account number found in the message as the message key.
• D.  Use a unique identifier such as a universally unique identifier (UUID) as the message key.

You have a Kafka consumer in production actively reading from a critical topic.
You need to update the offset of your consumer to start reading from the beginning of the topic.
Which action should you take?

• A.  Start a new consumer application with the same consumer group id.
• B.  Update the consumer group's offset to the earliest position using the kafka-consumer-groups CLI tool.
• C.  Temporarily configure the topic's retention.ms parameter to 0 to empty the topic.
• D.  Update the consumer configuration by setting auto.offset.reset=earliest.

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

• A.  batch.size
• B.  buffer.memory
• C.  send.buffer.bytes
• D.  max.block.size

(You are building real-time streaming applications using Kafka Streams.
Your application has a custom transformation.
You need to define custom processors in Kafka Streams.
Which tool should you use?)

• A.  Kafka Streams Custom Transformation Language
• B.  TopologyTestDriver
• C.  Processor API
• D.  Kafka Streams Domain Specific Language (DSL)

Where are source connector offsets stored?

• A.  offset, storage, partitions
• B.  storage.offset.topic
• C.  offset.storage.topic
• D.  topic.offset.config