skroutz/rafka

producer: Make Flush timeout configurable

Opened this issue · 0 comments

agis commented

Currently it's hard-coded to 5 seconds:

rafka/producer.go

Line 78 in f931155

unflushed := p.rdProd.Flush(5000)

We should also make it clear that this timeout sets a lower bound on how much time the shutdown process may take.