Confluent Confluent Certifications CCDAK Questions & Answers

• Question 11:

  How much should be the heap size of a broker in a production setup on a machine with 256 GB of RAM, in PLAINTEXT mode?

  A. 4 GB

  B. 128 GB

  C. 16 GB

  D. 512 MB

  Correct Answer: A

  In Kafka, a small heap size is needed, while the rest of the RAM goes automatically to the page cache (managed by the OS). The heap size goes slightly up if you need to enable SSL

• Question 12:

  Which KSQL queries write to Kafka?

  A. COUNT and JOIN

  B. SHOW STREAMS and EXPLAIN statements

  C. CREATE STREAM WITH and CREATE TABLE WITH

  D. CREATE STREAM AS SELECT and CREATE TABLE AS SELECT

  Correct Answer: D

• Question 13:

  Partition leader election is done by

  A. The consumers

  B. The Kafka Broker that is the Controller

  C. Zookeeper

  D. Vote amongst the brokers

  Correct Answer: B

• Question 14:

  What is not a valid authentication mechanism in Kafka?

  A. SASL/GSSAPI

  B. SASL/SCRAM

  C. SAML

  D. SSL

  Correct Answer: C

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

• Question 15:

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

  A. 9092

  B. 8088

  C. 8083

  D. 2181

  Correct Answer: B

  Default port of KSQL server is 8088

• Question 16:

  A consumer is configured with enable.auto.commit=false. What happens when close() is called on the consumer object?

  A. The uncommitted offsets are committed

  B. A rebalance in the consumer group will happen immediately

  C. The group coordinator will discover that the consumer stopped sending heartbeats. It will cause rebalance after session.timeout.ms

  Correct Answer: B

  Calling close() on consumer immediately triggers a partition rebalance as the consumer will not be available anymore.

• Question 17:

  A topic has three replicas and you set min.insync.replicas to 2. If two out of three replicas are not available, what happens when a produce request with acks=all is sent to broker?

  A. NotEnoughReplicasException will be returned

  B. Produce request is honored with single in-sync replica

  C. Produce request will block till one of the two unavailable partition is available again.

  Correct Answer: A

  With this configuration, a single in-sync replica becomes read-only. Produce request will receive NotEnoughReplicasException.

• Question 18:

  To read data from a topic, the following configuration is needed for the consumers

  A. all brokers of the cluster, and the topic name

  B. any broker to connect to, and the topic name

  C. the list of brokers that have the data, the topic name and the partitions list

  D. any broker, and the list of topic partitions

  Correct Answer: B

  All brokers can respond to Metadata request, so a client can connect to any broker in the cluster.

• Question 19:

  What exceptions may be caught by the following producer? (select two)

  ProducerRecord record =

  new ProducerRecord<>("topic1", "key1", "value1");

  try {

  producer.send(record);

  } catch (Exception e) {

  e.printStackTrace();

  }

  A. BrokerNotAvailableException

  B. SerializationException

  C. InvalidPartitionsException

  D. BufferExhaustedException

  Correct Answer: BD

  These are the client side exceptions that may be encountered before message is sent to the broker, and before a future is returned by the .send() method.

• Question 20:

  When auto.create.topics.enable is set to true in Kafka configuration, what are the circumstances under which a Kafka broker automatically creates a topic? (select three)

  A. Client requests metadata for a topic

  B. Consumer reads message from a topic

  C. Client alters number of partitions of a topic

  D. Producer sends message to a topic

  Correct Answer: ABD

  A kafka broker automatically creates a topic under the following circumstances- When a producer starts writing messages to the topic - When a consumer starts reading messages from the topic - When any client requests metadata for the topic