Kafka-based Job Queue for Python
-
Updated
Feb 4, 2022 - Python
Kafka-based Job Queue for Python
Golang Kafka consumer and producer example
Practical multithreading tutorials. Languages supported: C , Java, C#, Python, Javascript/Nodejs.
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 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
Add a description, image, and links to the producer-consumer topic page so that developers can more easily learn about it.
To associate your repository with the producer-consumer topic, visit your repo's landing page and select "manage topics."