add shutdown

Shuts down message stream threads spawned by kafka.

Also add
* producer/consumer integration tests, requires local zookeeper/kafka to be started up
There are already integration tests which load a YAML file with some settings (see `spec/fixtures/`), is this some different support?