Free CCDAK Exam Dumps PDF Preview

Question 1

Single choice

What is not a valid authentication mechanism in Kafka?

A
SASL/GSSAPI
B
SASL/SCRAM
C
SAML
D
SSL

Reveal answer details Close answer details

Correct answerC

Explanation

Learn more about security here
https://kafka.apache.org/documentation/#security

Question 2

Single choice

If I produce to a topic that does not exist, and the broker setting auto.create.topic.enable=true, what will happen?

A
Kafka will automatically create the topic with 1 partition and 1 replication factor
B
Kafka will automatically create the topic with the indicated producer settings num.partitions and default.replication.factor
C
Kafka will automatically create the topic with the broker settings num.partitions and default.replication.factor
D
Kafka will automatically create the topic with num.partitions=#of brokers and replication.factor=3

Reveal answer details Close answer details

Correct answerC

Explanation

The broker settings comes into play when a topic is auto created

Question 3

Single choice

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

Reveal answer details Close answer details

Correct answerB

Question 4

Multiple choice

What are the requirements for a Kafka broker to connect to a Zookeeper ensemble? (select two)

A
Unique value for each broker's zookeeper.connect parameter
B
Unique values for each broker's broker.id parameter
C
All the brokers must share the same broker.id
D
All the brokers must share the same zookeeper.connect parameter

Reveal answer details Close answer details

Correct answersB, D

Explanation

Each broker must have a unique broker id and connect to the same zk ensemble and root zNode

Question 5

Single choice

There are five brokers in a cluster, a topic with 10 partitions and replication factor of 3, and a quota of producer_bytes_rate of 1 MB/sec has been specified for the client.

What is the maximum throughput allowed for the client?

A
10 MB/s
B
0.33 MB/s
C
1 MB/s
D
5 MB/s

Reveal answer details Close answer details

Correct answerD

Explanation

Each producer is allowed to produce @ 1MB/s to a broker. Max throughput 5 * 1MB, because we have 5 brokers.

Question 6

Single choice

How much should be the heap size of a broker in a production setup on a machine with 256 GB of RAM, in PLAINTEXT mode?

A
4 GB
B
128 GB
C
16 GB
D
512 MB

Reveal answer details Close answer details

Correct answerA

Explanation

In Kafka, a small heap size is needed, while the rest of the RAM goes automatically to the page cache (managed by the OS). The heap size goes slightly up if you need to enable SSL

Question 7

Single choice

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?

A
NotEnoughReplicasException will be returned
B
Produce request is honored with single in-sync replica
C
Produce request will block till one of the two unavailable partition is available again.

Reveal answer details Close answer details

Correct answerA

Explanation

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

Question 8

Single choice

How will you find out all the partitions without a leader?

A
kafka-topics.sh --broker-list localhost:9092 --describe --under-replicated-partitions
B
kafka-topics.sh --bootstrap-server localhost:2181 --describe --unavailable-partitions
C
kafka-topics.sh --zookeeper localhost:2181 --describe --unavailable-partitions
D
kafka-topics.sh --zookeeper localhost:2181 --describe --under-replicated-partitions

Reveal answer details Close answer details

Correct answerC

Explanation

Please note that as of Kafka 2.2, the --zookeeper option is deprecated and you can now usekafka- topics.sh --bootstrap-server localhost:9092 --describe --unavailable-partitions

Question 9

Single choice

Where are KSQL-related data and metadata stored?

A
Kafka Topics
B
Zookeeper
C
PostgreSQL database
D
Schema Registry

Reveal answer details Close answer details

Correct answerA

Explanation

metadata is stored in and built from the KSQL command topic. Each KSQL server has its own in-memory version of the metastore.

Question 10

Single choice

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

Reveal answer details Close answer details

Correct answerB

Explanation

unclean.leader.election.enable=true allows non ISR replicas to become leader, ensuring availability but losing consistency as data loss will occur

Question 11

Single choice

In Avro, removing a field that does not have a default is a__schema evolution

A
breaking
B
full
C
backward
D
forward

Reveal answer details Close answer details

Correct answerC

Explanation

Clients with new schema will be able to read records saved with old schema.

Question 12

Single choice

You want to sink data from a Kafka topic to S3 using Kafka Connect. There are 10 brokers in the cluster, the topic has 2 partitions with replication factor of 3.

How many tasks will you configure for the S3 connector?

A
10
B
6
C
3
D
2

Reveal answer details Close answer details

Correct answerD

Explanation

You cannot have more sink tasks (= consumers) than the number of partitions, so 2.

Question 13

Single choice

A producer application was sending messages to a partition with a replication factor of 2 by connecting to Broker 1 that was hosting partition leader.
If the Broker 1 goes down, what will happen?

A
The producer will automatically produce to the broker that has been elected leader
B
The topic will be unavailable
C
The producer will stop working

Reveal answer details Close answer details

Correct answerA

Explanation

Once the client connects to any broker, it is connected to the entire cluster and in case of leadership changes, the clients automatically do a Metadata Request to an available broker to find out who is the new leader for the topic. Hence the producer will automatically keep on producing to the correct Kafka Broker

Question 14

Multiple choice

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

Reveal answer details Close answer details

Correct answersB, D

Explanation

Preferred leader is a broker that was leader when topic was created. It is preferred because when partitions are first created, the leaders are balanced between brokers. Otherwise, any of the in-sync replicas (ISR) will be elected leader, as long as unclean.leader.election=false (by default)

Question 15

Single choice

You want to perform table lookups against a KTable everytime a new record is received from the KStream.

What is the output of KStream-KTable join?

A
KTable
B
GlobalKTable
C
You choose between KStream or KTable
D
Kstream

Reveal answer details Close answer details

Correct answerD

Explanation

Here KStream is being processed to create another KStream.

Question 16

Single choice

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

Reveal answer details Close answer details

Correct answerC

Explanation

we have two tables, so the max number of tasks is 2

Question 17

Single choice

A producer is sending messages with null key to a topic with 6 partitions using the DefaultPartitioner.

Where will the messages be stored?

A
Partition 5
B
Any of the topic partitions
C
The partition for the null key
D
Partition 0

Reveal answer details Close answer details

Correct answerB

Question 18

Single choice

To continuously export data from Kafka into a target database, I should use

A
Kafka Producer
B
Kafka Streams
C
Kafka Connect Sink
D
Kafka Connect Source

Reveal answer details Close answer details

Correct answerC

Explanation

Kafka Connect Sink is used to export data from Kafka to external databases and Kafka Connect Source is used to import from external databases into Kafka.

Question 19

Multiple choice

Which of the following errors are retriable from a producer perspective? (select two)

A
MESSAGE_TOO_LARGE
B
INVALID_REQUIRED_ACKS
C
NOT_ENOUGH_REPLICAS
D
NOT_LEADER_FOR_PARTITION
E
TOPIC_AUTHORIZATION_FAILED

Reveal answer details Close answer details

Correct answersC, D

Explanation

Both of these are retriable errors, others non-retriable errors. See the full list of errors and their "retriable" status here
https://kafka.apache.org/protocol#protocol_error_codes

Question 20

Single choice

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

A
acks=1
B
acks=0
C
acks=all

Reveal answer details Close answer details

Correct answerA

Explanation

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

Question 21

Single choice

Two consumers share the same group.id (consumer group id). Each consumer will

A
Read mutually exclusive offsets blocks on all the partitions
B
Read all the data on mutual exclusive partitions
C
Read all data from all partitions

Reveal answer details Close answer details

Correct answerB

Explanation

Each consumer is assigned a different partition of the topic to consume.

Question 22

Single choice

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

Reveal answer details Close answer details

Correct answerC

Explanation

auto.offset.reset=none means that the consumer will crash if the offsets it's recovering from have been deleted from Kafka, which is the case here, as 10 < 45

Question 23

Single choice

If I want to send binary data through the REST proxy to topic "test_binary", it needs to be base64 encoded.
A consumer connecting directly into the Kafka topic A.

A
"test_binary" will receive
B
binary data
C
avro data
D
json data
E
base64 encoded data, it will need to decode it

Reveal answer details Close answer details

Correct answerB

Explanation

On the producer side, after receiving base64 data, the REST Proxy will convert it into bytes and then send that bytes payload to Kafka. Therefore consumers reading directly from Kafka will receive binary data.

Free CCDAK Exam Dumps Preview

Confluent Certified Developer for Apache Kafka Certification Examination

PREVIEW CONTENTS · 2 VOLUMES

QUESTION 1

QUESTION 2

QUESTION 3

QUESTION 4

QUESTION 5

QUESTION 6

QUESTION 7

QUESTION 8

QUESTION 9

QUESTION 10

QUESTION 11

QUESTION 12

QUESTION 13

QUESTION 14

QUESTION 15

QUESTION 16

QUESTION 17

QUESTION 18

QUESTION 19

QUESTION 20

QUESTION 21

QUESTION 22

QUESTION 23

VOL	TYPE	QUESTIONS
1	Single choice	20
2	Multiple choice	3