Consumer now multiplexes topic-partitions [breaks API]