Hi Ewen,
Thank you for your response. It’s much faster after changing to async.
Cheers,Huy, Le Van
On Thursday, Dec 11, 2014 at 7:08 p.m., Ewen Cheslack-Postava
, wrote:
Did you set producer.type to async when creating your producer? The console
producer uses async by default, but
Key = (String)key;
return Integer.parseInt(stringKey) % numPartitions;
}
The only difference between kafka-console-producer.sh code and my code is that
I use a custom partitioner. I have no idea why it’s so slow.
Best regards,Huy, Le Van
