Confluent CCDAK Confluent Certified Developer for Apache Kafka Certification Examination Exam Practice Test

In Avro, adding an element to an enum without a default is a __ schema evolution

What is the protocol used by Kafka clients to securely connect to the Confluent REST Proxy?

You are receiving orders from different customer in an "orders" topic with multiple partitions. Each message has the customer name as the key. There is a special customer named ABC that generates a lot of orders and you would like to reserve a partition exclusively for ABC. The rest of the message should be distributed among other partitions. How can this be achieved?

There are 3 producers writing to a topic with 5 partitions. There are 5 consumers consuming from the topic. How many Controllers will be present in the cluster?

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?

Where are KSQL-related data and metadata stored?

You have a Kafka cluster and all the topics have a replication factor of 3. One intern at your company stopped a broker, and accidentally deleted all the data of that broker on the disk. What will happen if the broker is restarted?

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

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?

To transform data from a Kafka topic to another one, I should use

Once sent to a topic, a message can be modified

You are sending messages with keys to a topic. To increase throughput, you decide to increase the number of partitions of the topic. Select all that apply.

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

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)

How will you read all the messages from a topic in your KSQL query?

A client connects to a broker in the cluster and sends a fetch request for a partition in a topic. It gets an exception Not Leader For Partition Exception in the response. How does client handle this situation?

Which of these joins does not require input topics to be sharing the same number of partitions?

If a topic has a replication factor of 3...

What client protocol is supported for the schema registry? (select two)

In Java, Avro SpecificRecords classes are

You want to perform table lookups against a KTable everytime a new record is received from the KStream. What is the output of KStream-KTable join?

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