KQ: Kafka Job Queue for Python

KQ (Kafka Queue) is a Python library which lets you enqueue and execute jobs asynchronously using Apache Kafka. It uses kafka-python under the hood.

Requirements

• Apache Kafka 0.9+
• Python 3.6+

Installation

Install via pip:

pip install kq

Contents

• Getting Started
• Queue
• Worker
• Job
• Message
• Callback
• Serializer
• Logging