add shutdown

Shuts down message stream threads spawned by kafka.

Also add
* producer/consumer integration tests, requires local zookeeper/kafka to be started up
This test doesn't make any sense, there's a stub being put onto `consumer` and then the expectation is calling that stub we just created