Temp workaround for consuming off cluster with more than 500 partitions (issue #111)

This fix will be replaced by a proper implementation shortly.