It looks like existing consumers expect a single message as the block argument to `Consumer#consume` (as per the README). Perhaps we should change this to iterate over the `messages`, instead of breaking the current interface?