Upon detecting a broker failure, the Controller performs leader election among in-sync replicas and updates the new leader and ISR information in ZooKeeper. It then broadcasts this metadata update to all brokers in the cluster.

From Kafka documentation:

“The controller writes the new leader and ISR list to ZooKeeper and informs all brokers so they can update their metadata cache.”

B → Correct: New metadata written to ZooKeeper.

C → Correct: Brokers are updated via metadata propagation.

A → Incorrect: The Controller makes the decision, not ZooKeeper.

D → Incorrect: Producers and consumers learn about changes via brokers, not directly.

Page Reference:

Kafka: The Definitive Guide, 1st Edition, Chapter 6, p. 190–191

Apache Kafka Documentation: Controller Behavior & ZooKeeper Interactions

‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾

Kafka topics support two main cleanup policies:

delete: The default policy where Kafka deletes old log segments based on retention time or size.

compact: Enables log compaction, retaining only the latest value for each key.

From Kafka documentation:

“Valid cleanup.policy values are 'delete' and 'compact'.”

B → Invalid: 'default' is not a recognized cleanup policy.

D → Invalid: 'cleanup' is not a valid keyword in this context.

Page Reference:

Kafka: The Definitive Guide, 1st Edition, Chapter 6, p. 196–197

Apache Kafka Documentation: Topic Configs – cleanup.policy

‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾

Kafka supports multiple SASL mechanisms for authentication, including:

SASL/PLAIN – Username/password

SASL/GSSAPI – Kerberos-based

SASL/OAUTHBEARER – OAuth 2.0 token-based

From Apache Kafka documentation:

“Kafka supports the following SASL mechanisms: GSSAPI (Kerberos), PLAIN, SCRAM, OAUTHBEARER.”

B → SAML20 is not supported.

E → OTP is not a supported SASL mechanism.

Page Reference:

Kafka: The Definitive Guide, 1st Edition, Chapter 9, p. 280–284

Apache Kafka Documentation: Kafka SASL Authentication

‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾

In Kafka, a partition is a fundamental unit of parallelism and storage. Each topic in Kafka consists of one or more partitions, which are ordered, immutable sequences of records. Importantly, partitions themselves are broken down into segments on the disk. According to the official Kafka documentation:

“A partition is made up of one or more segment files on disk. Each segment is a continuous sequence of messages and each segment file is named after the offset of the first message it contains.”(Apache Kafka Documentation, "Log Basics" section).

Each partition resides in its own directory under the log.dirs configuration on the broker. The documentation states:“The log for each topic partition is stored in its own directory under the log.dirs configuration.”

Given these official clarifications:

Option A is incorrectbecause a partition is not represented by a single segment; rather, it can have multiple segments (as log segments are created to manage file sizes and facilitate compaction or deletion).

Option B is correctas it accurately states that a partition consists of multiple segments.

Option C is correctas all segments for a partition reside in a single directory.

Option D is incorrectbecause partition size is determined by the sum of all its segments, not just the largest one.