Open
Description
#Current defaults
DEFAULTS = {
'partitioner.class' => 'kafka.producer.DefaultPartitioner',
'request.required.acks' => '1',
'message.send.max.retries' => '0'
}.freeze
I'm thinking we should make:
request.required.acks
= -1 (needs ack from all ISR's, best durability)
message.send.max
= 3 (to made the tradeoff towards reliability, when the cost is possibility of dups)
Activity