test and fix consumer partitioning