Question 7

Select all that applies (select THREE)

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 8

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?

Correct Answer:B
A Custom Partitioner allows you to easily customise how the partition number gets computed from a source message.

Question 9

If I produce to a topic that does not exist, and the broker setting auto.create.topic.enable=true, what will happen?

Correct Answer:C
The broker settings comes into play when a topic is auto created

Question 10

Once sent to a topic, a message can be modified

Correct Answer:A
Kafka logs are append-only and the data is immutable

Question 11

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

Correct Answer:C
Consumers can set auto.offset.reset property to earliest to start consuming from beginning. For KSQL, SET 'auto.offset.reset'='earliest';

Question 12

How can you gracefully make a Kafka consumer to stop immediately polling data from Kafka and gracefully shut down a consumer application?

Correct Answer:A
See https://stackoverflow.com/a/37748336/3019499

START CCDAK EXAM