Confluent CCDAK Online Practice Questions and Exam Preparation

Confluent CCDAK Online Questions & Answers

• Question 1:

  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
  B. 20

  ---

  Explanation/Reference:

  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.

• Question 2:

  while (true) {

  ConsumerRecords records = consumer.poll(100); try {

  consumer.commitSync();

  } catch (CommitFailedException e) {

  log.error("commit failed", e)

  }

  for (ConsumerRecord record records)

  {

  System.out.printf("topic = %s, partition = %s, offset =

  %d, customer = %s, country = %s

  ",

  record.topic(), record.partition(),

  record.offset(), record.key(), record.value());

  }

  }

  What kind of delivery guarantee this consumer offers?

  A. Exactly-once
  B. At-least-once
  C. At-most-once
  C. At-most-once

  ---

  Explanation/Reference:

  Here offset is committed before processing the message. If consumer crashes before processing the message, message will be lost when it comes back up.

• Question 3:

  Where are the dynamic configurations for a topic stored?

  A. In Zookeeper
  B. In an internal Kafka topic __topic_configuratins
  C. In server.properties
  D. On the Kafka broker file system
  A. In Zookeeper
  D. On the Kafka broker file system

• Question 4:

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

  A. Compression will be increased
  B. Throughput will be decreased
  C. It will force all brokers in Kafka to acknowledge the producerRecord
  D. Batching will be increased
  B. Throughput will be decreased

  ---

  Explanation/Reference:

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

• Question 5:

  You want to send a message of size 3 MB to a topic with default message size configuration. How does KafkaProducer handle large messages?

  A. KafkaProducer divides messages into sizes of max.request.size and sends them in order
  B. KafkaProducer divides messages into sizes of message.max.bytes and sends them in order
  C. MessageSizeTooLarge exception will be thrown, KafkaProducer will not retry and return exception immediately
  D. MessageSizeTooLarge exception will be thrown, KafkaProducer retries until the number of retries are exhausted
  C. MessageSizeTooLarge exception will be thrown, KafkaProducer will not retry and return exception immediately

  ---

  Explanation/Reference:

  MessageSizeTooLarge is not a retryable exception.

• Question 6:

  Select all the way for one consumer to subscribe simultaneously to the following topics - topic.history, topic.sports, topic.politics? (select two)

  A. consumer.subscribe(Pattern.compile("topic\..*"));
  B. consumer.subscribe("topic.history"); consumer.subscribe("topic.sports"); consumer.subscribe("topic.politics");
  C. consumer.subscribePrefix("topic.");
  D. consumer.subscribe(Arrays.asList("topic.history", "topic.sports", "topic.politics"));
  A. consumer.subscribe(Pattern.compile("topic\..*"));
  D. consumer.subscribe(Arrays.asList("topic.history", "topic.sports", "topic.politics"));

  ---

  Explanation/Reference:

  Multiple topics can be passed as a list or regex pattern.

• Question 7:

  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
  D. In the _schemas topic

  ---

  Explanation/Reference:

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

• Question 8:

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

  A. 9092
  B. 8088
  C. 8083
  D. 2181
  B. 8088

  ---

  Explanation/Reference:

  Default port of KSQL server is 8088

• Question 9:

  Your manager would like to have topic availability over consistency. Which setting do you need to change in order to enable that?

  A. compression.type
  B. unclean.leader.election.enable
  C. min.insync.replicas
  B. unclean.leader.election.enable

  ---

  Explanation/Reference:

  unclean.leader.election.enable=true allows non ISR replicas to become leader, ensuring availability but losing consistency as data loss will occur

• Question 10:

  is KSQL ANSI SQL compliant?

  A. Yes
  B. No
  B. No

  ---

  Explanation/Reference:

  KSQL is not ANSI SQL compliant, for now there are no defined standards on streaming SQL languages