= (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
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
e...@confluent.io, wrote:
Did you set producer.type to async when creating your producer? The console
producer uses async
