This library lets Python applications enqueue and execute background jobs asynchronously using Apache Kafka.
KQ (Kafka Queue) is a lightweight Python library for asynchronous job processing, leveraging Apache Kafka. Users can define a `worker.py` module to set up a `kq.Worker` that consumes jobs from a Kafka topic. Jobs are enqueued by instantiating a `kq.Queue` and calling `queue.enqueue()` with a function and its arguments.
This library lets Python applications enqueue and execute background jobs asynchronously using Apache Kafka.
Developers needing a straightforward Python solution for offloading tasks to a Kafka-backed job queue should use this.
KQ (Kafka Queue) is a lightweight Python library which lets you enqueue and execute jobs asynchronously using Apache Kafka. It uses kafka-python under the hood.
Install using pip:
pip install kq