Hi Gray,

The Java producer will block on send() when the buffer is full and
block.on.buffer.full = true (
http://kafka.apache.org/documentation.html#newproducerconfigs). If you set
the config to false the send() call will throw a BufferExhaustedException
which, in your case, can be caught and ignore and allow the message to drop
on the floor.

Guozhang



On Wed, Feb 25, 2015 at 5:08 AM, Gary Ogden <gog...@gmail.com> wrote:

> Say the entire kafka cluster is down and there's no brokers to connect to.
> Is it possible to use the java producer send method and not block until
> there's a timeout?  Is it as simple as registering a callback method?
>
> We need the ability for our application to not have any kind of delay when
> sending messages and the cluster is down.  It's ok if the messages are lost
> when the cluster is down.
>
> Thanks!
>



-- 
-- Guozhang

Reply via email to