You may also need to set the retries to something high, I think. I think the default is something like 1 or 3 so it will try a few times then give up.
-Jay On Mon, Oct 27, 2014 at 6:01 PM, Libo Yu <yu_l...@hotmail.com> wrote: > 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. > > > >
