Apache Kafka Kafka Admin & Operations 2

Question 1

How do you reset a consumer group's offsets to the earliest available message using the CLI?

Accepted Answer

kafka-consumer-groups.sh --reset-offsets --to-earliest --execute

Answer

kafka-consumer-groups.sh with --reset-offsets --to-earliest --execute resets all offsets for a consumer group to the beginning of each partition.

Question 2

What is the primary role of the Kafka Controller broker in a cluster?

Accepted Answer

It handles partition leader election and broker failure recovery

Answer

The Kafka Controller is an elected broker responsible for managing partition leader elections, tracking broker liveness, and coordinating cluster state changes.

Question 3

What is a 'preferred replica' in Kafka?

Accepted Answer

The first replica in the assigned replica list, which is the ideal partition leader

Answer

The preferred replica is the first entry in the partition's assigned replica list; Kafka tries to keep this replica as the leader for balanced load distribution.

Question 4

What information does `kafka-log-dirs.sh` provide?

Accepted Answer

Disk usage and replica lag information per broker and partition

Answer

kafka-log-dirs.sh reports disk usage per log directory and per partition, along with replica offset lag, helping identify storage hotspots.

Question 5

Which JMX metric reports the number of under-replicated partitions in a Kafka cluster?

Accepted Answer

kafka.server:type=ReplicaManager,name=UnderReplicatedPartitions

Answer

kafka.server:type=ReplicaManager,name=UnderReplicatedPartitions counts partitions with fewer in-sync replicas than the configured replication factor, a key health indicator.

Apache Kafka Practice Test

Apache Kafka Practice Test

Apache Kafka Kafka Admin & Operations 2