Go module implementing a kafka client wrapper, abstracting messages to go channels - View it on GitHub