thanks ghenke, that was a quick response. I will test and will let you know
if i have some questions.
On Tue, Mar 31, 2015 at 11:17 PM, Grant Henke <ghe...@cloudera.com> wrote:
> 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
>
--
SunilKalva
