fix multiple partitions of the same topic not consumed