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
