add shutdown

Shuts down message stream threads spawned by kafka.

Also add
* producer/consumer integration tests, requires local zookeeper/kafka to be started up
looks like if we add this as a runtime dependency (which add_dependency aliases) ```hermann_jars.rb``` file would get regenerated upon installation of this gem.  I don't think we want this behavior, thus keeping it a development_dep