But I found that synchronization is needed for record reading(read
the input Key and Value) and result output.

I use Spring Batch for that. it has io buffering builtin and it is very easy to 
use and well documented.

Reply via email to