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 file should be reworked to act as an integration test in a similar style to the existing integration tests