Weekend Sale Limited Time 70% Discount Offer - Ends in 0d 00h 00m 00s - Coupon code: merry71

Free Confluent Certified Developer for Apache Kafka Certification Examination Practice Questions

Exams4sure Dumps

Exam style questions across every CCDAK domain

Last Update 20 hours ago
Total Questions : 90

Start with our free CCDAK practice questions, carefully crafted to mirror the domains, phrasing, and difficulty of the real Confluent Certified Developer exam. Each CCDAK exam question comes with a detailed rationale that explains not just which answer is correct but why the others fall short. That's how concepts stick. Use the free set to benchmark yourself: identify your Confluent weak domains, see where you're losing marks, and build a focused study plan in minutes.

CCDAK PDF

CCDAK PDF (Printable)
$46.5
$154.99

CCDAK Testing Engine

CCDAK PDF (Printable)
$51
$169.99

CCDAK PDF + Testing Engine

CCDAK PDF (Printable)
$63.9
$212.99
Question # 11

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

Options:

A.  

Messages with the same key are routed to a deterministically selected partition, enabling order guarantees within that partition.

B.  

Kafka brokers allow you to add more partitions to a given topic, without impacting the data flow for existing keys.

C.  

It provides a mechanism for encrypting messages at the partition level to ensure secure data transmission.

D.  

Consumers can filter messages in real time based on the message key without processing unrelated messages.

Discussion 0
Question # 12

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 must be added to the messagesWhich three configuration parameters are necessary?(Select three.)

Options:

A.  

errors.tolerance=all

B.  

errors.deadletterqueue.topic.name=DLQ-Topic

C.  

errors.deadletterqueue.context.headers.enable=true

D.  

errors.tolerance=none

E.  

errors.log.enable=true

F.  

errors.log.include.messages=true

Discussion 0
Question # 13

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

(Select two.)

Options:

A.  

It is mandatory to subscribe to a topic before calling assign() to assign partitions.

B.  

The consumer chooses which partition to read without any assignment from brokers.

C.  

The consumer group will not be rebalanced if a consumer leaves the group.

D.  

All topics must have the same number of partitions to use assign() API.

Discussion 0
Question # 14

You are building a system for a retail store selling products to customers.

Which three datasets should you model as a GlobalKTable?

(Select three.)

Options:

A.  

Inventory of products at a warehouse

B.  

All purchases at a retail store occurring in real time

C.  

Customer profile information

D.  

Log of payment transactions

E.  

Catalog of products

Discussion 0
Question # 15

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

Options:

A.  

batch.size

B.  

max.block.size

C.  

buffer.memory

D.  

send.buffer.bytes

Discussion 0
Question # 16

The producer code below features a Callback class with a method called onCompletion().

When will the onCompletion() method be invoked?

Options:

A.  

When a consumer sends an acknowledgement to the producer

B.  

When the producer puts the message into its socket buffer

C.  

When the producer batches the message

D.  

When the producer receives the acknowledgment from the broker

Discussion 0
Question # 17

(You need to send a JSON message on the wire. The message key is a string.

How would you do this?)

Options:

A.  

Specify a key serializer class for the JSON contents of the message’s value. Set the value serializer class to null.

B.  

Specify a value serializer class for the JSON contents of the message’s value. Set a key serializer for the string value.

C.  

Specify a value serializer class for the JSON contents of the message’s value. Set the key serializer class to null.

D.  

Specify a value serializer class for the JSON contents of the message’s value. Set the key serializer class to JSON.

Discussion 0
Question # 18

You are experiencing low throughput from a Java producer.

Metrics show low I/O thread ratio and low I/O thread wait ratio.

What is the most likely cause of the slow producer performance?

Options:

A.  

Compression is enabled.

B.  

The producer is sending large batches of messages.

C.  

There is a bad data link layer (layer 2) connection from the producer to the cluster.

D.  

The producer code has an expensive callback function.

Discussion 0
Question # 19

You are creating a Kafka Streams application to process retail data.

Match the input data streams with the appropriate Kafka Streams object.

Options:

Discussion 0
Question # 20

(You are writing to a Kafka topic with producer configuration acks=all.

The producer receives acknowledgements from the broker but still creates duplicate messages due to network timeouts and retries.

You need to ensure that duplicate messages are not created.

Which producer configuration should you set?)

Options:

A.  

enable.auto.commit=true

B.  

retries=2147483647max.in.flight.requests.per.connection=5enable.idempotence=false

C.  

retries=2147483647max.in.flight.requests.per.connection=1enable.idempotence=true

D.  

retries=0max.in.flight.requests.per.connection=5enable.idempotence=true

Discussion 0

Free Exams Sample Questions