Single in-process implementation of the sarama golang kafka APIs - View it on GitHub