Skip to content
This repository was archived by the owner on Mar 10, 2025. It is now read-only.
This repository was archived by the owner on Mar 10, 2025. It is now read-only.

Update producer default settings #112

@jamescway

Description

@jamescway
#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)

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions