Confluent CCDAK Exam Practice Test Instant Access

Question 1

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

AKafka Producer

BKafka Streams

CKafka Connect Sink

DKafka Connect Source

Answer : C

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 2

Which of the following is not an Avro primitive type?

Astring

Blong

Cint

Ddate

Enull

Answer : D

date is a logical type

Question 3

An ecommerce wesbite sells some custom made goods. What's the natural way of modeling this data in Kafka streams?

APurchase as stream, Product as stream, Customer as stream

BPurchase as stream, Product as table, Customer as table

CPurchase as table, Product as table, Customer as table

DPurchase as stream, Product as table, Customer as stream

Answer : B

Mostly-static data is modeled as a table whereas business transactions should be modeled as a stream.

Question 4

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

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

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

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

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

Answer : C

As of Kafka 2.3, the kafka-topics.sh command can take --bootstrap-server localhost:9092 as an argument. You could also use the (now deprecated) option of --zookeeper localhost:2181.

Question 5

Your streams application is reading from an input topic that has 5 partitions. You run 5 instances of your application, each with num.streams.threads set to 5. How many stream tasks will be created and how many will be active?

A5 created, 1 active

B5 created, 5 active

C25 created, 25 active

D25 created, 5 active

Answer : D

One partition is assigned a thread, so only 5 will be active, and 25 threads (i.e. tasks) will be created

Question 6

What happens if you write the following code in your producer? producer.send(producerRecord).get()

ACompression will be increased

BThroughput will be decreased

CIt will force all brokers in Kafka to acknowledge the producerRecord

DBatching will be increased

Answer : B

Using Future.get() to wait for a reply from Kafka will limit throughput.

Question 7

Suppose you have 6 brokers and you decide to create a topic with 10 partitions and a replication factor of 3. The brokers 0 and 1 are on rack A, the brokers 2 and 3 are on rack B, and the brokers 4 and 5 are on rack C. If the leader for partition 0 is on broker 4, and the first replica is on broker 2, which broker can host the last replica? (select two)

Answer : B, E

When you create a new topic, partitions replicas are spreads across racks to maintain availability. Hence, the Rack A, which currently does not hold the topic partition, will be selected for the last replica

Confluent CCDAK Certified Developer for Apache Kafka Exam Practice Test