reorg.
increase queue size to # of consumers * 100.
the bottleneck is disk read.