Whats your "linger.ms" and "batch.size" ?
Thanks,
Mayuresh
On Wed, Apr 1, 2015 at 5:51 AM, sunil kalva <sambarc...@gmail.com> wrote:
> I am trying to simulate "sync" call using following code,
>
> try {
>
> Future<RecordMetadata> send = producer.send(new
> ProducerRecord<byte[],byte[]>("the-topic", "key".getBytes(),
> "value".getBytes())).get();
>
> send.get();
>
> System.out.println("Time = " + (System.currentTimeMillis() - b));
> } catch (Exception e) {
>
> }
>
> And i am using new "org.apache.kafka.clients.producer.KafkaProducer"
> class for sending messages, each message is taking more than 100ms,
> am i missing something. If i use old "kafka.javaapi.producer.Produce"
> it is giving the desired throughput.
>
> Please advice me hot to fix this.
>
>
> On Tue, Mar 31, 2015 at 11:21 PM, sunil kalva <sambarc...@gmail.com>
> wrote:
>
> > 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
> >
>
>
>
> --
> SunilKalva
>
--
-Regards,
Mayuresh R. Gharat
(862) 250-7125
