Confluent CCDAK Exam Questions Instant Access

Question 1

To prevent network-induced duplicates when producing to Kafka, I should use

Amax.in.flight.requests.per.connection=1

Benable.idempotence=true

Cretries=200000

Dbatch.size=1

Answer : B

Producer idempotence helps prevent the network introduced duplicates. More details herehttps://cwiki.apache.org/confluence/display/KAFKA/Idempotent+Producer

Question 2

How often is log compaction evaluated?

AEvery time a new partition is created

BEvery time a segment is closed

CEvery time a message is sent to Kafka

DEvery time a message is flushed to disk

Answer : B

Log compaction is evaluated every time a segment is closed. It will be triggered if enough data is 'dirty' (see dirty ratio config)

Question 3

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?

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

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

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

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

Answer : C

two partitions groups - one for each application so that all messages are delivered to both the application. 4 consumers in each as there are 4 partitions of the topic, and you cannot have more consumers per groups than the number of partitions (otherwise they will be inactive and wasting resources)

Question 4

Where are the ACLs stored in a Kafka cluster by default?

AInside the broker's data directory

BUnder Zookeeper node /kafka-acl/

CIn Kafka topic __kafka_acls

DInside the Zookeeper's data directory

Answer : A

ACLs are stored in Zookeeper node /kafka-acls/ by default.

Question 5

A consumer wants to read messages from a specific partition of a topic. How can this be achieved?

ACall subscribe(String topic, int partition) passing the topic and partition number as the arguments

BCall assign() passing a Collection of TopicPartitions as the argument

CCall subscribe() passing TopicPartition as the argument

Answer : B

assign() can be used for manual assignment of a partition to a consumer, in which case subscribe() must not be used. Assign() takes a collection of TopicPartition object as an argument https://kafka.apache.org/23/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#assign-java.util.Collection-

Question 6

What is not a valid authentication mechanism in Kafka?

ASASL/GSSAPI

BSASL/SCRAM

CSAML

DSSL

Answer : C

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

Question 7

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.

Confluent Certified Developer for Apache Kafka CCDAK Exam Questions