Confluent Confluent Certifications CCDAK Questions & Answers

• Question 71:

  We have a store selling shoes. What dataset is a great candidate to be modeled as a KTable in Kafka Streams?

  A. Money made until now

  B. The transaction stream

  C. Items returned

  D. Inventory contents right now

  Correct Answer: C

• Question 72:

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

  A. In the Schema Registry embedded SQL database

  B. In the Zookeeper node /schemas

  C. In the message bytes themselves

  D. In the _schemas topic

  Correct Answer: D

  The Schema Registry stores all the schemas in the _schemas Kafka topic

• Question 73:

  Select all that applies (select THREE)

  A. min.insync.replicas is a producer setting

  B. acks is a topic setting

  C. acks is a producer setting

  D. min.insync.replicas is a topic setting

  E. min.insync.replicas matters regardless of the values of acks

  F. min.insync.replicas only matters if acks=all

  Correct Answer: CDF

  acks is a producer setting min.insync.replicas is a topic or broker setting and is only effective when acks=all

• Question 74:

  How does a consumer commit offsets in Kafka?

  A. It directly sends a message to the __consumer_offsets topic

  B. It interacts with the Group Coordinator broker

  C. It directly commits the offsets in Zookeeper

  Correct Answer: B

  Consumers do not directly write to the __consumer_offsets topic, they instead interact with a broker that has been elected to manage that topic, which is the Group Coordinator broker

• Question 75:

  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?

  A. 5 created, 1 active

  B. 5 created, 5 active

  C. 25 created, 25 active

  D. 25 created, 5 active

  Correct Answer: D

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

• Question 76:

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

  A. Call subscribe(String topic, int partition) passing the topic and partition number as the arguments

  B. Call assign() passing a Collection of TopicPartitions as the argument

  C. Call subscribe() passing TopicPartition as the argument

  Correct 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.ht ml#assign-java.util.Collection-

• Question 77:

  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=1 can't produce?

  A. 0

  B. 3

  C. 1

  D. 2

  Correct Answer: D

  min.insync.replicas does not impact producers when acks=1 (only when acks=all)

• Question 78:

  Which of the following event processing application is stateless? (select two)

  A. Read events from a stream and modifies them from JSON to Avro

  B. Publish the top 10 stocks each day

  C. Read log messages from a stream and writes ERROR events into a high-priority stream and the rest of the events into a low-priority stream

  D. Find the minimum and maximum stock prices for each day of trading

  Correct Answer: AC

  Stateless means processing of each message depends only on the message, so converting from JSON to Avro or filtering a stream are both stateless operations

• Question 79:

  Which Kafka CLI should you use to consume from a topic?

  A. kafka-console-consumer

  B. kafka-topics

  C. kafka-console

  D. kafka-consumer-groups

  Correct Answer: A

  Examplekafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic test --from- beginning

• Question 80:

  A customer has many consumer applications that process messages from a Kafka topic. Each consumer application can only process 50 MB/s. Your customer wants to achieve a target throughput of 1 GB/s. What is the minimum number of partitions will you suggest to the customer for that particular topic?

  A. 10

  B. 20

  C. 1

  D. 50

  Correct Answer: B

  each consumer can process only 50 MB/s, so we need at least 20 consumers consuming one partition so that 50 * 20 = 1000 MB target is achieved.