Batching with async producer in Samza (currently not used by any ML algorithm)