On 15.01.2019 13:27, Rajini Sivaram wrote: > Hi Jan, > > If the queue of one Processor is full, we move to the next Processor > immediately without blocking. So as long as the queue of any Processor is > not full, we accept the connection immediately. If the queue of all > Processors are full, we assign a Processor and block until the connection > can be added. There is currently no timeout for this. The PR is here: > https://github.com/apache/kafka/pull/6022 > > Thanks, > > Rajini > > On Tue, Jan 15, 2019 at 12:02 PM Jan Filipiak <jan.filip...@trivago.com> > wrote: >
Thank you, the code makes it obvious! From the KIP this wasnt to obvious for me. Any concerns about logging a warn when we hit the mayBlock case? I would argue that the broker is pretty stressed out under this conditions and clients may run into connect time-outs. Best jan @Collin could you please try using threads?
