Great !!. The sync mode and those properties are orthogonal. Thanks,
Mayuresh On Wed, Apr 1, 2015 at 10:46 AM, sunil kalva <sambarc...@gmail.com> wrote: > thanks grant > by changing linger.ms=0,batch.size=1, problem solved > > > On Wed, Apr 1, 2015 at 11:11 PM, Grant Henke <ghe...@cloudera.com> wrote: > > > They can. You can read more about configuring the new java producer here: > > http://kafka.apache.org/documentation.html#newproducerconfigs > > > > Thanks, > > Grant > > > > On Wed, Apr 1, 2015 at 12:34 PM, sunil kalva <sambarc...@gmail.com> > wrote: > > > >> Does these config params has effect when i try to simulate "sync" mode > by > >> not passing callback ? > >> > >> On Wed, Apr 1, 2015 at 10:32 PM, Mayuresh Gharat < > >> gharatmayures...@gmail.com> wrote: > >> > >>> 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 > >>> > >> > >> > >> > >> -- > >> SunilKalva > >> > > > > > > > > -- > > Grant Henke > > Solutions Consultant | Cloudera > > ghe...@cloudera.com | twitter.com/ghenke <http://twitter.com/gchenke> | > > linkedin.com/in/granthenke > > > > > > -- > SunilKalva > -- -Regards, Mayuresh R. Gharat (862) 250-7125
