This seems to be a bug of 0.8.1
More info:
queue.enqueue.timeout.ms is explicitly set to -1.
queue.buffering.max.messages is explicitly set o 10000.
But still, when the net cable was unplugged, the producer did not block at all
and
all messages were "sent".
> From: yu_l...@hotmail.com
> To: users@kafka.apache.org
> Subject: question about async publishing for 0.8.1
> Date: Mon, 27 Oct 2014 15:20:38 -0400
>
> Hi team,
>
> I am testing async publishing + acknowledgement.
>
> Assume all settings are the default and queue.buffering.max.messages is 10k.
> I use a simple for loop to publish 100k messages. In the process, I unplugged
> the net cable.
>
> What should I expect in this case?
> I assume the send will be blocked when the queue is full. But surprisingly,
> the send() is not blocked and all msgs are "sent". Thanks.
>
