Initialize sets up the kafka package.

Shutdown shuts down the kafka package.

ConsumerState contains data that is required to create a Kafka consumer.

Stream is an implementation of shezmu.Stremer for Kafka messaging queue.

Subscriber is a dummy structure that implements shezmu.Subscriber interface.