Most Recent Confluent CCDAK Exam Dumps

Prepare for the Confluent Certified Developer for Apache Kafka exam with our extensive collection of questions and answers. These practice Q&A are updated according to the latest syllabus, providing you with the tools needed to review and test your knowledge.

QA4Exam focus on the latest syllabus and exam objectives, our practice Q&A are designed to help you identify key topics and solidify your understanding. By focusing on the core curriculum, These Questions & Answers helps you cover all the essential topics, ensuring you're well-prepared for every section of the exam. Each question comes with a detailed explanation, offering valuable insights and helping you to learn from your mistakes. Whether you're looking to assess your progress or dive deeper into complex topics, our updated Q&A will provide the support you need to confidently approach the Confluent CCDAK exam and achieve success.

The questions for CCDAK were last updated on Feb 21, 2025.

Viewing page 1 out of 30 pages.
Viewing questions 1-5 out of 150 questions

Get All 150 Questions & Answers

Question No. 1

In the Kafka consumer metrics it is observed that fetch-rate is very high and each fetch is small. What steps will you take to increase throughput?

AIncrease fetch.max.wait

BIncrease fetch.max.bytes

CDecrease fetch.max.bytes

DDecrease fetch.min.bytes

EIncrease fetch.min.bytes

Show Answer

Correct Answer: E

This will allow consumers to wait and receive more bytes in each fetch request.

Question No. 2

A topic "sales" is being produced to in the Americas region. You are mirroring this topic using Mirror Maker to the European region. From there, you are only reading the topic for analytics purposes. What kind of mirroring is this?

APassive-Passive

BActive-Active

CActive-Passive

Show Answer

Correct Answer: C

This is active-passing as the replicated topic is used for read-only purposes only

Question No. 3

A topic has three replicas and you set min.insync.replicas to 2. If two out of three replicas are not available, what happens when a produce request with acks=all is sent to broker?

ANotEnoughReplicasException will be returned

BProduce request is honored with single in-sync replica

CProduce request will block till one of the two unavailable partition is available again.

Show Answer

Correct Answer: A

With this configuration, a single in-sync replica becomes read-only. Produce request will receive NotEnoughReplicasException.

Question No. 4

To get acknowledgement of writes to only the leader partition, we need to use the config...

Aacks=1

Backs=0

Cacks=all

Show Answer

Correct Answer: A

Producers can set acks=1 to get acknowledgement from partition leader only.

Question No. 5

StreamsBuilder builder = new StreamsBuilder();

KStream textLines = builder.stream("word-count-input");

KTable wordCounts = textLines

.mapValues(textLine -> textLine.toLowerCase())

.flatMapValues(textLine -> Arrays.asList(textLine.split("\W+")))

.selectKey((key, word) -> word)

.groupByKey()

.count(Materialized.as("Counts"));

wordCounts.toStream().to("word-count-output", Produced.with(Serdes.String(), Serdes.Long()));

builder.build();

What is an adequate topic configuration for the topic word-count-output?

Amax.message.bytes=10000000

Bcleanup.policy=delete

Ccompression.type=lz4

Dcleanup.policy=compact

Show Answer

Correct Answer: D

Result is aggregated into a table with key as the unique word and value its frequency. We have to enable log compaction for this topic to align the topic's cleanup policy with KTable semantics.

Unlock All Questions for Confluent CCDAK Exam

Full Exam Access, Actual Exam Questions, Validated Answers, Anytime Anywhere, No Download Limits, No Practice Limits

Get All 150 Questions & Answers