There's no nice way for the client to disconnect a PartitionConsumer stream #41
Description
The stream method in PartitionConsumer will never finish. This causes the consume example to never finish.
One method for ending the stream on the client side is to wrap the stream call in a promise like the integration tests do. This is a bit gross and should be abstracted.