add flush batches to producer, flush before close
add preliminary speedtest