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.

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

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

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

consumer/producer/rpc library built over aioamqp

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.

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.

Producer-consumer problem visualization

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

A TPL Dataflow-compatible ISourceBlock supporting priority queueing