An extension of the kafka-python package that adds features like multiprocess consumers. - View it on GitHub