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-console-consumer.sh --from-beginning --reset

Answer

kafka-offsets.sh --reset --start-earliest

Answer

kafka-topics.sh --reset-offsets --to-earliest

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

It routes all producer requests to the correct partition leader

Answer

It manages ZooKeeper connections on behalf of all brokers

Answer

It compresses and deduplicates messages before storage

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 replica with the most up-to-date data at any given time

Answer

The replica residing on the broker with the least network load

Answer

The replica that was most recently added to the ISR

Question 4

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

Accepted Answer

Disk usage and replica lag information per broker and partition

Answer

A listing of all Kafka log segment filenames

Answer

Compression ratio statistics for stored messages

Answer

The schedule for upcoming log segment rotation

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=LeaderCount

Answer

kafka.controller:type=KafkaController,name=ActiveControllerCount

Answer

kafka.network:type=RequestMetrics,name=TotalTimeMs

Question 6

What does the `auto.create.topics.enable` broker configuration setting control?

Accepted Answer

Whether Kafka automatically creates a topic when it is first referenced by a producer or consumer

Answer

Whether Kafka automatically rebalances partitions across new brokers

Answer

Whether Kafka automatically adjusts the replication factor for under-replicated topics

Answer

Whether consumers can create private topics for internal use

Question 7

Which configuration setting controls how often Kafka flushes data from OS page cache to disk?

Accepted Answer

log.flush.interval.ms

Answer

log.segment.bytes

Answer

log.roll.hours

Answer

log.index.interval.bytes