Handle New Topic Creation

Adds ensure_topic_exists to KafkaClient, redirects test case to use
that.  Fixes #113 and fixes #150.
That's a great idea.  I'll get back to this based on the style review in the other conversation as soon as the world isn't literally blowing up at work.