Confluent Certified Developer for Apache Kafka Certification Examination

Question 1

(You create an Orders topic with 10 partitions.
The topic receives data at high velocity.
Your Kafka Streams application initially runs on a server with four CPU threads.
You move the application to another server with 10 CPU threads to improve performance.
What does this example describe?)

A. Plain Scaling

B. Scaling Out

C. Vertical Scaling

D. Horizontal Scaling

Correct Answer: C

Explanation: Only visible for Actualtests4sure members. You can sign-up / login (it's free).

Question 2

(Your configuration parameters for a Source connector and Connect worker are:
* offset.flush.interval.ms=60000
* offset.flush.timeout.ms=500
* offset.storage.topic=connect-offsets
* offset.storage.replication.factor=-1
Which two statements match the expected behavior?
Select two.)

A. The connector will commit offsets to the broker default offsets topic.

B. The connector will commit offsets to a topic called connect-offsets.

C. The connector will wait 500 ms before trying to commit offsets for tasks.

D. The offsets topic will use the broker default replication factor.

Correct Answer: B,D

Explanation: Only visible for Actualtests4sure members. You can sign-up / login (it's free).

Question 3

The producer code below features a Callback class with a method called onCompletion().
In the onCompletion() method, when the request is completed successfully, what does the value metadata.
offset() represent?

A. The ID of the partition to which the message was committed

B. The sequential ID of the message committed into a partition

C. Its position in the producer's batch of messages

D. The number of bytes that overflowed beyond a producer batch of messages

Correct Answer: B

Explanation: Only visible for Actualtests4sure members. You can sign-up / login (it's free).

Question 4

(You are developing a Java application that includes a Kafka consumer.
You need to integrate Kafka client logs with your own application logs.
Your application is using the Log4j2 logging framework.
Which Java library dependency must you include in your project?)

A. SLF4J implementation for Log4j 1.2 (org.slf4j:slf4j-log4j12)

B. SLF4J implementation for Log4j2 (org.apache.logging.log4j:log4j-slf4j-impl)

C. Just the Log4j2 dependency of the application

D. None, the correct dependency will be added transitively by the Kafka client

Correct Answer: B

Explanation: Only visible for Actualtests4sure members. You can sign-up / login (it's free).

Question 5

(You want to enrich the content of a topic by joining it with key records from a second topic.
The two topics have a different number of partitions.
Which two solutions can you use?
Select two.)

A. Repartition one topic to a new topic with the same number of partitions as the other topic (co- partitioning constraint) and use a KStream-KTable join.

B. Use a GlobalKTable for one of the topics where data does not change frequently and use a KStream- GlobalKTable join.

C. Use a KStream-KTable join; Kafka Streams will automatically repartition the topics to satisfy the co- partitioning constraint.

D. Create as many Kafka Streams application instances as the maximum number of partitions of the two topics and use a KStream-KTable join.

Correct Answer: A,B

Explanation: Only visible for Actualtests4sure members. You can sign-up / login (it's free).

Question 6

(You are developing a Kafka Streams application with a complex topology that has multiple sources, processors, sinks, and sub-topologies.
You are working in a development environment and do not have access to a real Kafka cluster or topics.
You need to perform unit testing on your Kafka Streams application.
Which should you use?)

A. TestProducer, TestConsumer

B. MockProducer, MockConsumer

C. TopologyTestDriver

D. KafkaUnitTestDriver

Correct Answer: C

Explanation: Only visible for Actualtests4sure members. You can sign-up / login (it's free).

Question 7

Your Kafka cluster has five brokers. The topic t1 on the cluster has:
Two partitions
Replication factor = 4
min.insync.replicas = 3You need strong durability guarantees for messages written to topic t1.You configure a producer acks=all and all the replicas for t1 are in-sync.How many brokers need to acknowledge a message before it is considered committed?

A. 2

B. 5

C. 3

D. 4

Correct Answer: C

Explanation: Only visible for Actualtests4sure members. You can sign-up / login (it's free).

Question 8

You need to collect logs from a host and write them to a Kafka topic named 'logs-topic'. You decide to use Kafka Connect File Source connector for this task.
What is the preferred deployment mode for this connector?

A. Distributed mode

B. SingleCluster mode

C. Standalone mode

D. Parallel mode

Correct Answer: C

Explanation: Only visible for Actualtests4sure members. You can sign-up / login (it's free).

Question 9

You need to correctly join data from two Kafka topics.
Which two scenarios will allow for co-partitioning?
(Select two.)

A. Both topics have the same number of partitions.

B. Both topics have the same key and partitioning strategy.

C. Both topics have the same value schema.

D. Both topics have the same retention time.

Correct Answer: A,B

Explanation: Only visible for Actualtests4sure members. You can sign-up / login (it's free).

Question 10

(You want to read messages from all partitions of a topic in every consumer instance of your application.
How do you do this?)

A. Use the assign() method using all topic-partitions of the topic as argument.

B. Use the subscribe() method with an empty consumer group name configuration.

C. Use the subscribe() method with a regular expression argument.

D. Use the assign() method with the topic name as argument.

Correct Answer: A

Explanation: Only visible for Actualtests4sure members. You can sign-up / login (it's free).

Confluent Certified Developer for Apache Kafka Certification Examination - CCDAK Exam Practice Test

Latest Update

Useful Links

Contact Us