I think you are looking at is this section:
> If you want to simulate a simple blocking call you can do the following:
>
> producer.send(new ProducerRecord<byte[],byte[]>("the-topic",
> "key".getBytes(), "value".getBytes())).get();
>
> What that is doing is calling .get() on the Future returned by the send
method. This will block until the message is sent or an exception is
thrown.
The documentation for Future is here:
http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html#get()
On Tue, Mar 31, 2015 at 12:30 PM, sunil kalva <sambarc...@gmail.com> wrote:
> Hi
> According to this
>
> http://kafka.apache.org/082/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html
> documentation, if i don't pass callback it will work as blocking call, Does
> it mean that message will be immediately sent to kafka cluster and all
> possible exceptions will be throws immediately if not able to send ?
>
> --
> SunilKalva
>
--
Grant Henke
Solutions Consultant | Cloudera
ghe...@cloudera.com | 920-980-8979
twitter.com/ghenke <http://twitter.com/gchenke> | linkedin.com/in/granthenke
