kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joel Koshy <jjkosh...@gmail.com>
Subject Re: Async producer and close()
Date Tue, 13 Mar 2012 22:17:44 GMT
Yes - it blocks until all the send threads' message queues have been
drained.

Joel

On Tue, Mar 13, 2012 at 1:04 PM, Niek Sanders <niek.sanders@gmail.com>wrote:

> Will calling close() on the async producer block until the message
> queue has emptied?
>
> If not, how does one wait till all messages have been sent out?
>
> Thanks,
> Niek
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message