How To Prepare and Pass the CCDAK Exam Successfully?

test2022-02-15T08:16:18+00:00

If you are thinking about how to prepare and pass your CCDAK exam, you are in the right place. You should pass the Confluent Certified Developer for Apache Kafka Certification Examination to earn your CCDAK Certification. The newest CCDAK exam dumps are based on the exam objectives and are designed to help you assess your understanding. It will guide you through CCDAK Questions Answers for your Exam preparation. To assess your level of preparation, take this CCDAK practice test first!

Page 1 of 4

1. How can you gracefully make a Kafka consumer to stop immediately polling data from Kafka and gracefully shut down a consumer application?

Call consumer.wakeUp() and catch a WakeUpException

Call consumer.poll() in another thread

Kill the consumer thread

2. To allow consumers in a group to resume at the previously committed offset, I need to set the proper value for...

value.deserializer

auto.offset.resets

group.id

enable.auto.commit

3. You are using JDBC source connector to copy data from 3 tables to three 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?

4. When using the Confluent Kafka Distribution, where does the schema registry reside?

As a separate JVM component

As an in-memory plugin on your Zookeeper cluster

As an in-memory plugin on your Kafka Brokers

As an in-memory plugin on your Kafka Connect Workers

5. An ecommerce website maintains two topics - a high volume "purchase" topic with 5 partitions and low volume "customer" topic with 3 partitions. You would like to do a stream-table join of these topics .

How should you proceed?

Repartition the purchase topic to have 3 partitions

Repartition customer topic to have 5 partitions

Model customer as a GlobalKTable

Do a KStream / KTable join after a repartition step

6. A kafka topic has a replication factor of 3 and min.insync.replicas setting of 2 .

How many brokers can go down before a producer with acks=all can't produce?

7. A Zookeeper ensemble contains 3 servers.

Over which ports the members of the ensemble should be able to communicate in default configuration? (select three)

2181

3888

443

2888

9092

8. 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)

Enable compression

Disable compression

Increase batch.size

Decrease batch.size

Decrease linger.ms Increase linger.ms

9. How will you find out all the partitions where one or more of the replicas for the partition are not in-sync with the leader?

kafka-topics.sh -- bootstrap-server localhost:9092 --describe --unavailable- partitions

kafka-topics.sh -- zookeeper localhost:2181 --describe -- unavailable- partitions

kafka-topics.sh -- broker-list localhost:9092 -- describe --under-replicated-partitions

kafka-topics.sh -- zookeeper localhost:2181 --describe -- under-replicated-partitions

10. Which of the following Kafka Streams operators are stateful? (select all that apply)

flatmap

reduce

joining

count

peek

aggregate

Page 2 of 4

11. What is true about partitions? (select two)

A broker can have a partition and its replica on its disk

You cannot have more partitions than the number of brokers in your cluster

A broker can have different partitions numbers for the same topic on its disk

Only out of sync replicas are replicas, the remaining partitions that are in sync are also leader

A partition has one replica that is a leader, while the other replicas are followers

12. 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?

The producer will automatically produce to the broker that has been elected leader

The topic will be unavailable

The producer will stop working

13. In Kafka Streams, by what value are internal topics prefixed by?

tasks-<number>

application.id

group.id

kafka-streams-

14. What information isn't stored inside of Zookeeper? (select two)

Schema Registry schemas

Consumer offset

ACL inforomation

Controller registration

Broker registration info

15. A bank uses a Kafka cluster for credit card payments .

What should be the value of the property unclean.leader.election.enable?

FALSE

TRUE

16. Using the Confluent Schema Registry, where are Avro schema stored?

In the Schema Registry embedded SQL database

In the Zookeeper node /schemas

In the message bytes themselves

In the _schemas topic

17. Kafka is configured with following parameters - log.retention.hours = 168 log.retention.minutes = 168 log.retention.ms = 168 How long will the messages be retained for?

Broker will not start due to bad configuration

168 ms

168 hours

168 minutes

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

Kafka will automatically create the topic with 1 partition and 1 replication factor

Kafka will automatically create the topic with the indicated producer settings num.partitions and default.replication.factor

Kafka will automatically create the topic with the broker settings num.partitions and default.replication.factor

Kafka will automatically create the topic with num.partitions=#of brokers and replication.factor=3

19. What is not a valid authentication mechanism in Kafka?

SASL/GSSAPI

SASL/SCRAM

SAML

SSL

20. The rule "same key goes to the same partition" is true unless...

the number of producer changes

the number of kafka broker changes

the number of partition changes

the replication factor changes

Page 3 of 4

21. In Avro, removing or adding a field that has a default is a __ schema evolution

full

backward

breaking

forward

22. How do you create a topic named test with 3 partitions and 3 replicas using the Kafka CLI?

bin/kafka-topics.sh --create --broker-list localhost:9092 --replication-factor 3 --partitions 3 --topic test

bin/kafka-topics-create.sh --zookeeper localhost:9092 --replication-factor 3 --partitions 3 --topic test

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 3 -- partitions 3 --topic test

bin/kafka-topics.sh --create --bootstrap-server localhost:2181 --replication-factor 3 -- partitions 3 --topic test

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

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

Any of the replicas

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

An in-sync replica

24. What are the requirements for a Kafka broker to connect to a Zookeeper ensemble? (select

two)

Unique value for each broker's zookeeper.connect parameter

Unique values for each broker's broker.id parameter

All the brokers must share the same broker.id

All the brokers must share the same zookeeper.connect parameter

25. If you enable an SSL endpoint in Kafka, what feature of Kafka will be lost?

Cross-cluster mirroring

Support for Avro format

Zero copy

Exactly-once delivery

26. Which of the following is not an Avro primitive type?

string

long

int

date

null

27. What is the default port that the KSQL server listens on?

9092

8088

8083

2181

28. What is the protocol used by Kafka clients to securely connect to the Confluent REST

Proxy?

Kerberos

SASL

HTTPS (SSL/TLS)

HTTP

29. An ecommerce wesbite sells some custom made goods .

What 's the natural way of modeling this data in Kafka streams?

Purchase as stream, Product as stream, Customer as stream

Purchase as stream, Product as table, Customer as table

Purchase as table, Product as table, Customer as table

Purchase as stream, Product as table, Customer as stream

30. 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?

Increase fetch.max.wait

Increase fetch.max.bytes

Decrease fetch.max.bytes

Decrease fetch.min.bytes

Increase fetch.min.bytes

Page 4 of 4

31. To produce data to a topic, a producer must provide the Kafka client with...

the list of brokers that have the data, the topic name and the partitions list

any broker from the cluster and the topic name and the partitions list

all the brokers from the cluster and the topic name

any broker from the cluster and the topic name

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

Kafka Connect Sink

Kafka Connect Source

Consumer + Producer

Kafka Streams

33. A topic receives all the orders for the products that are available on a commerce site. Two applications want to process all the messages independently - order fulfilment and monitoring.

The topic has 4 partitions, how would you organise the consumers for optimal performance and resource usage?

Create 8 consumers in the same group with 4 consumers for each application

Create two consumers groups for two applications with 8 consumers in each

Create two consumer groups for two applications with 4 consumers in each

Create four consumers in the same group, one for each partition - two for fulfilment and two for monitoring

34. A consumer is configured with enable.auto.commit=false .

What happens when close() is called on the consumer object?

The uncommitted offsets are committed

A rebalance in the consumer group will happen immediately

The group coordinator will discover that the consumer stopped sending heartbeats. It will cause rebalance after session.timeout.ms

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

KStream-KTable join

KStream-KStream join

KStream-GlobalKTable

KTable-KTable join

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

Read mutually exclusive offsets blocks on all the partitions

Read all the data on mutual exclusive partitions

Read all data from all partitions

37. When auto.create.topics.enable is set to true in Kafka configuration, what are the circumstances under which a Kafka broker automatically creates a topic? (select three)

Client requests metadata for a topic

Consumer reads message from a topic

Client alters number of partitions of a topic

Producer sends message to a topic

38. Once sent to a topic, a message can be modified

Yes