Kafka-based Job Queue for Python

Golang Kafka consumer and producer example

Practical multithreading tutorials. Languages supported: C++, Java, C#, Python, Javascript/Nodejs.

redisqueue provides a producer and consumer of a queue that uses Redis streams

Small Flask app with scalable, asynchronous backend workers deployed on Kubernetes.

a Python voice chat app that uses WebSockets to send encrypted data between a multi-threaded client and server

Distributed task redisqueue(最简单python分布式函数调度框架)

consumer/producer/rpc library built over aioamqp

It can flexibly control async task, ignore the order of sending and receiving, allow binding of asynchronous tasks in pending state, and support producer consumer mode and order mode

A producer-consumer solution for Golang

Using NATS Jetstream as queue manager to replace RabbitMQ, etc.

A synchronized persistent Queue class

A tutorial on building a real-time data streaming application pipeline with Apache Kafka🔥🔥🔥

Lightweight Module for Asynchronous Event Driven Systems

Producer-consumer problem solution using semaphore and mutex

Efficient Pandas and Ray Kafka Producer for python using actor model.

Producer-consumer problem visualization

It will take backup of given topic and store that into either local filesystem or S3.It will also restore from given local filesystem or S3.

Julia Channels with defined length: Buffered and threaded iterators for machine learning.

A TPL Dataflow-compatible ISourceBlock supporting priority queueing