Kafka-based Job Queue for Python

Golang Kafka consumer and producer example

高并发RedisQueue,分布式爬虫利器(High concurrency RedisQueue,Distributed crawler weapon)

consumer/producer/rpc library built over aioamqp

A producer-consumer solution for Golang

A synchronized persistent Queue class

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

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

Lightweight Module for Asynchronous Event Driven Systems

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

C#.NET based DevFast NuGet package

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

Event Bus asynchronous queuing with many Producer and Consumer implementations

In order to deploy Confluent Kafka in the machine, the project starts 4 Docker containers (ZooKeeper, Kafka, Kafka-REST-Proxy and Kafka-Topics-UI). It also starts 3 other containers (1 Producer and 2 Consumers) to emulate message publish/consume using crypto currencies JSON data.

A TPL Dataflow-compatible ISourceBlock supporting priority queueing

Repositório para aulas e exercícios da matéria: Programação Paralela e Distribuída (INE5645) e Computação Distribuida (INE5625).

NiFi processor emulating queue/topic patterns on top of Redis

Piping made Eazy!

Galena is a topic producer-consumer library built on top of GenStage for Elixir.

Home automation interface based on Arduino, UARTs and CAN transceivers.

Producer-consumer problem visualization

Programming with C course: pointer, multi-process, multi-thread, concurrency, semaphores, Socket, PIPE, FIFO

Code repository for all the articles on design patterns at codepumpkin.com

Very Fast MPMC C++ implementation

Producer Consumer problem solved in Elixir

计算机系统中一些重要实验

Qluent provides a very simple Fluent API and wrapper classes around the Microsoft Azure Storage SDK

A C++17 implementation of a circular buffer

Java implementation of assignments from the "System Architecture" lab, held at the University of Karlsruhe during Summer Term 2007.