acks
all
(default): Provides the strongest durability guarantee. The broker will wait for the message to be successfully persisted to the storage layer (either BookKeeper or object storage) before sending an acknowledgment response.
1
: Requires acknowledgement only from the owner broker. Provides moderate durability with better performance than all
.
0
: Provides no durability guarantees but maximum throughput. The broker does not send any response, so you cannot verify message delivery or determine message offsets.
default_topic_conf
sub-configurationdefault.topic.config
sub-configurationretries
0
, retries are enabled (the default is 0
, which disables retries). With retries enabled, message re-ordering can occur if a retry succeeds after subsequent messages have already been written successfully.
max.in.flight.requests.per.connection
1
. This ensures only one request can be sent to the broker at a time, preventing any potential re-ordering. Note that when retries are disabled, the broker preserves the order of writes it receives, but failed sends can create gaps in the message sequence.
batch.size
linger.ms
compression.type
/tmp
directory. If you don’t have write access to the /tmp
directory because it’s set to noexec
, you can specify an alternate directory path that you have write access to:
batch.num.messages
buffer.memory
max.block.ms
before raising an exception.
request.timeout.ms