Great !!. The sync mode and those properties are orthogonal.
Thanks,
Mayuresh
On Wed, Apr 1, 2015 at 10:46 AM, sunil kalva wrote:
> thanks grant
> by changing linger.ms=0,batch.size=1, problem solved
>
>
> On Wed, Apr 1, 2015 at 11:11 PM, Grant Henke wrote:
>
> > They can. You can read more a
thanks grant
by changing linger.ms=0,batch.size=1, problem solved
On Wed, Apr 1, 2015 at 11:11 PM, Grant Henke 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
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 wrote:
> Does these config params has effect when i try to simulate "sync" mode by
> not passing cal
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 wrote:
> Whats your "linger.ms" and "batch.size" ?
>
> Thanks,
>
> Mayuresh
>
> On Wed, Apr 1, 2015 at 5:51 AM, sunil kalva wrote:
>
> > I am trying
Whats your "linger.ms" and "batch.size" ?
Thanks,
Mayuresh
On Wed, Apr 1, 2015 at 5:51 AM, sunil kalva wrote:
> I am trying to simulate "sync" call using following code,
>
> try {
>
> Future send = producer.send(new
> ProducerRecord("the-topic", "key".getBytes(),
> "value".getBytes())).get
I am trying to simulate "sync" call using following code,
try {
Future send = producer.send(new
ProducerRecord("the-topic", "key".getBytes(),
"value".getBytes())).get();
send.get();
System.out.println("Time = " + (System.currentTimeMillis() - b));
} catch (Exception e) {
}
And i
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 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
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("the-topic",
> "key".getBytes(), "value".getBytes())).get();
>
> What that is doing is calling .get() on the Future returned by the send
meth
