Backpressure when queue is full

We uncovered a case where a key customer was losing events due to the way this library is configured/built.

With the flush_interval=2 (default is 0.5), flush_at=100 and max_queue_size=1000 (default 10k), their queue got full during peak hours and they started dropping events.

Their recommended solution is very reasonable:

Ideally the library would provide back pressure by blocking/waiting for acknowledgement when flushing a batch of events vs having to configure a max_queue_size.

We should implement some way to block when the queue is full, or some way to let the user know the queue size.

Non è indicato alcun file, test o punto di ingresso. Inizia tracciando il modo in cui flush_interval, flush_at e max_queue_size controllano la consegna degli eventi, quindi chiarisci se il comportamento previsto consiste nel bloccarsi quando la coda è piena o nell’esporne le dimensioni. Il lavoro completato deve includere un comportamento definito per la coda piena e la copertura del caso di perdita di eventi segnalato.