Free CCDAK: Confluent Certified Developer for Apache Kafka Certification Examination Exam Questions and Answers

is KSQL ANSI SQL compliant?

• AA. Yes
• BB. No

In Kafka Streams, by what value are internal topics prefixed by?

• AA. tasks-<number>
• BB. application.id
• CC. group.id
• DD. kafka-streams-

A consumer starts and has auto.offset.reset=none, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 10 for the topic before. Where will the consumer read from?

• AA. offset 45
• BB. offset 10
• CC. it will crash
• DD. offset 2311

What exceptions may be caught by the following producer? (select two) ProducerRecord<String, String> record = new ProducerRecord<>("topic1", "key1", "value1"); try { producer.send(record); } catch (Exception e) { e.printStackTrace(); }

Select 2 answers.

• AA. BrokerNotAvailableException
• BB. SerializationException
• CC. InvalidPartitionsException
• DD. BufferExhaustedException

A bank uses a Kafka cluster for credit card payments. What should be the value of the property unclean.leader.election.enable?

• AA. FALSE
• BB. TRUE

When using the Confluent Kafka Distribution, where does the schema registry reside?

• AA. As a separate JVM component
• BB. As an in-memory plugin on your Zookeeper cluster
• CC. As an in-memory plugin on your Kafka Brokers
• DD. As an in-memory plugin on your Kafka Connect Workers

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

• AA. kafka-console-consumer
• BB. kafka-topics
• CC. kafka-console
• DD. kafka-consumer-groups

In Avro, removing or adding a field that has a default is a schema evolution

• AA. full
• BB. backward
• CC. breaking
• DD. forward

You have a consumer group of 12 consumers and when a consumer gets killed by the process management system, rather abruptly, it does not trigger a graceful shutdown of your consumer. Therefore, it takes up to 10 seconds for a rebalance to happen. The business would like to have a 3 seconds rebalance time. What should you do? (select two)

Select 2 answers.

• AA. Increase session.timeout.ms
• BB. Decrease session.timeout.ms
• CC. Increase heartbeat.interval.ms
• DD. decrease max.poll.interval.ms
• EE. increase max.poll.interval.ms
• FF. Decrease heartbeat.interval.ms

There are 3 brokers in the cluster. You want to create a topic with a single partition that is resilient to one broker failure and one broker maintenance. What is the replication factor will you specify while creating the topic?

• AA. 6
• BB. 3
• CC. 2
• DD. 1