Apache Kafka Kafka Producers & Consumers 2

Question 1

What happens when a consumer's `session.timeout.ms` expires without a heartbeat?

Accepted Answer

The consumer is considered dead and a rebalance is triggered

Answer

If the broker does not receive a heartbeat from a consumer within session.timeout.ms, it marks that consumer as failed and triggers a group rebalance.

Question 2

Which producer configuration controls the maximum size of a single request sent to the broker?

Accepted Answer

max.request.size

Answer

max.request.size limits the size (in bytes) of a request the producer sends to the broker, capping the size of individual produce requests.

Question 3

What does `auto.offset.reset=earliest` do for a new consumer group?

Accepted Answer

Reads from the very beginning of the topic

Answer

earliest causes the consumer to start reading from the earliest available offset when no committed offset exists for the group.

Question 4

How does a Kafka producer achieve idempotency?

Accepted Answer

By setting enable.idempotence=true, which assigns a unique producer ID and sequence numbers

Answer

Enabling idempotence assigns a Producer ID and per-partition sequence numbers so the broker can deduplicate retried messages.

Question 5

What is the role of `buffer.memory` in a Kafka producer?

Accepted Answer

Total bytes of memory the producer uses to buffer records waiting to be sent

Answer

buffer.memory is the total amount of memory the producer allocates for buffering records before they are transmitted to brokers.

Apache Kafka Practice Test

Apache Kafka Practice Test

Apache Kafka Kafka Producers & Consumers 2