wolff

wolff copied to clipboard

Handle initial connection failure

1

I start `wolff` producers during the app initialization with `wolff:ensure_supervised_producers/3`, but it fails if my kafka server is unavailable. I need to start them anyway so they will queue messages...

SukhikhN

The current default value for `replayq_max_total_bytes` is 2GB. Meaning if this limit is reached, wolff will start dropping produce requests (with a logging though) We should change default to inifnity.

zmstone

Previously, the `wolff_producer` implementation is aggresive when try to enqueue newly received calls, even when max_linger_ms is set to non-zero because the linger was implemented from the popping end of...

zmstone