Your Kafka cluster has five brokers. The topic t1 on the cluster has two partitions, and it has replication.factor
= 4, min.insync.replicas = 3.
You want to have strong durability guarantees for messages written to topic t1.
If you configure a producer 'acks=all', how many brokers need to acknowledge a message before it is considered committed?

You have a Kafka client application that has real-time processing requirements.
What are the most important metrics available in Kafka that you should monitor?

In stream processing applications, handling out-of-order data can be a challenge which could affect the implemented business logic.
Which type of Join handles out-of-order records?

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?

Which configurations define which connector is deployed?