Add logging of workers stopping.
Tests for startWorker and stopWorker.
Handle unknown mtypes more explicitly while consuming.
Skip UnhandledConsumerType test for now because I don't think we can clean-up nicely after having a consumer raise an error yet.