Massive New Year Special Limited Time 65% Discount Offer - Ends in 0d 00h 00m 00s - Coupon code: dpm65

CCDAK Questions and Answers

Question # 4

By default, which replica will be elected as a partition leader? (select two)

A.

Preferred leader broker if it is in-sync and auto.leader.rebalance.enable=true

B.

Any of the replicas

C.

Preferred leader broker if it is in-sync and auto.leader.rebalance.enable=false

D.

An in-sync replica

Full Access
Question # 5

How does a consumer commit offsets in Kafka?

A.

It directly sends a message to the __consumer_offsets topic

B.

It interacts with the Group Coordinator broker

C.

It directly commits the offsets in Zookeeper

Full Access
Question # 6

What is the disadvantage of request/response communication?

A.

Scalability

B.

Reliability

C.

Coupling

D.

Cost

Full Access
Question # 7

How will you set the retention for the topic named “my-topic” to 1 hour?

A.

Set the broker config log.retention.ms to 3600000

B.

Set the consumer config retention.ms to 3600000

C.

Set the topic config retention.ms to 3600000

D.

Set the producer config retention.ms to 3600000

Full Access
Question # 8

You are running a Kafka Streams application in a Docker container managed by Kubernetes, and upon application restart, it takes a long time for the docker container to replicate the state and get back to processing the data. How can you improve dramatically the application restart?

A.

Mount a persistent volume for your RocksDB

B.

Increase the number of partitions in your inputs topic

C.

Reduce the Streams caching property

D.

Increase the number of Streams threads

Full Access
Question # 9

while (true) {

ConsumerRecords records = consumer.poll(100);

try {

consumer.commitSync();

} catch (CommitFailedException e) {

log.error("commit failed", e)

}

for (ConsumerRecord record records)

{

System.out.printf("topic = %s, partition = %s, offset =

%d, customer = %s, country = %s

",

record.topic(), record.partition(),

record.offset(), record.key(), record.value());

}

}

What kind of delivery guarantee this consumer offers?

A.

Exactly-once

B.

At-least-once

C.

At-most-once

Full Access
Question # 10

You are using JDBC source connector to copy data from 2 tables to two Kafka topics. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers. How many tasks are launched?

A.

6

B.

1

C.

2

D.

3

Full Access
Question # 11

A consumer starts and has auto.offset.reset=none, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 10 for the topic before. Where will the consumer read from?

A.

offset 45

B.

offset 10

C.

it will crash

D.

offset 2311

Full Access
Question # 12

Which of these joins does not require input topics to be sharing the same number of partitions?

A.

KStream-KTable join

B.

KStream-KStream join

C.

KStream-GlobalKTable

D.

KTable-KTable join

Full Access
Question # 13

Which is an optional field in an Avro record?

A.

doc

B.

name

C.

namespace

D.

fields

Full Access
Question # 14

If a topic has a replication factor of 3...

A.

3 replicas of the same data will live on 1 broker

B.

Each partition will live on 4 different brokers

C.

Each partition will live on 2 different brokers

D.

Each partition will live on 3 different brokers

Full Access
Question # 15

A kafka topic has a replication factor of 3 and min.insync.replicas setting of 1. What is the maximum number of brokers that can be down so that a producer with acks=all can still produce to the topic?

A.

3

B.

0

C.

2

D.

1

Full Access
Question # 16

There are two consumers C1 and C2 belonging to the same group G subscribed to topics T1 and T2. Each of the topics has 3 partitions. How will the partitions be assigned to consumers with Partition Assigner being Round Robin Assigner?

A.

C1 will be assigned partitions 0 and 2 from T1 and partition 1 from T2. C2 will have partition 1 from T1 and partitions 0 and 2 from T2.

B.

Two consumers cannot read from two topics at the same time

C.

C1 will be assigned partitions 0 and 1 from T1 and T2, C2 will be assigned partition 2 from T1 and T2.

D.

All consumers will read from all partitions

Full Access
Question # 17

Your manager would like to have topic availability over consistency. Which setting do you need to change in order to enable that?

A.

compression.type

B.

unclean.leader.election.enable

C.

min.insync.replicas

Full Access
Question # 18

How often is log compaction evaluated?

A.

Every time a new partition is created

B.

Every time a segment is closed

C.

Every time a message is sent to Kafka

D.

Every time a message is flushed to disk

Full Access
Question # 19

To transform data from a Kafka topic to another one, I should use

A.

Kafka Connect Sink

B.

Kafka Connect Source

C.

Consumer + Producer

D.

Kafka Streams

Full Access
Question # 20

Your producer is producing at a very high rate and the batches are completely full each time. How can you improve the producer throughput? (select two)

A.

Enable compression

B.

Disable compression

C.

Increase batch.size

D.

Decrease batch.size

E.

Decrease linger.ms

Increase linger.ms

Full Access
Question # 21

Consumer failed to process record # 10 and succeeded in processing record # 11. Select the course of action that you should choose to guarantee at least once processing

A.

Commit offsets at 10

B.

Do not commit until successfully processing the record #10

C.

Commit offsets at 11

Full Access
Question # 22

What is a generic unique id that I can use for messages I receive from a consumer?

A.

topic + partition + timestamp

B.

topic + partition + offset

C.

topic + timestamp

Full Access
dumpsmate guaranteed to pass
24/7 Customer Support

DumpsMate's team of experts is always available to respond your queries on exam preparation. Get professional answers on any topic of the certification syllabus. Our experts will thoroughly satisfy you.

Site Secure

mcafee secure

TESTED 22 Jan 2022