single buffer, each consume assigned to new partition id (now using circular number, even not a round robin)
Merge pull request #27 from octo47/feature/fix_partitioning

single buffer, each consume assigned to new partition id (now using circ...