Kafka Producers & Consumers Flashcards

Which producer configuration controls the maximum time (in ms) a producer will wait before sending a batch of records?

Answer: linger.ms

linger.ms specifies the delay a producer adds before sending a batch, allowing more records to accumulate.

What does setting `acks=all` mean for a Kafka producer?

Answer: The producer waits for acknowledgment from all in-sync replicas

acks=all (or acks=-1) requires the leader to wait for the full set of in-sync replicas to acknowledge the record.

Which consumer configuration determines how frequently the consumer offsets are committed automatically?

Answer: auto.commit.interval.ms

auto.commit.interval.ms sets the frequency (in milliseconds) at which the consumer's offsets are committed when enable.auto.commit is true.

What is the purpose of the `max.poll.records` consumer configuration?

Answer: Limits the maximum number of records returned in a single poll() call

max.poll.records controls the maximum number of records that a single call to poll() will return.

When a Kafka producer sends a message without a key, how is the partition selected?

Answer: Round-robin across available partitions

Without a key, the default partitioner distributes messages in round-robin fashion across all available partitions.

Which setting must be enabled for a Kafka consumer to commit offsets automatically?

Answer: enable.auto.commit=true

enable.auto.commit=true instructs the consumer to automatically commit offsets at the interval specified by auto.commit.interval.ms.