Postgres change data capture to streams, queues, and search indexes like Kafka, SQS, Elasticsearch, HTTP endpoints, and more

A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues

Kafka-based Job Queue for Python

Native C# client for Kafka queue servers.

提供各种客户端接入阿里云 消息队列 Kafka 的demo工程(Provide a demo project for various clients to access Alibaba Cloud message queue Kafka)

Kafka-based message queue

Parallel Apache Kafka client wrapper with per message ACK, client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.

Laravel Enqueue message queue extension. Supports AMQP, Amazon SQS, Kafka, Google PubSub, Redis, STOMP, Gearman, Beanstalk and others

Apache Kafka is an open-source distributed event streaming platform used by thousands of companies. uForwarder aims to address several pain points while using Apache Kafka for pub-sub message queueing at scale, including partition scalability and head-of-line blocking.

A lightweight, HTTP-centric, log-based (Kafka-like) message queue.

Kafka Queue driver for Laravel

A Distributed, Fault-Tolerant Message Queue from Scratch. Inspired by Apache Kafka

A sample of non-blocking retries and dead letter topics (aka reliable reprocessing and dead letter queues) with Apache Kafka using Spring Boot and Spring Kafka.

Library to support priority queuing in Kafka

Python Django as Producer and Consumer using Apache Kafka for content queue and Celery for task queue

Python API for the Kafka Message Queue

Apache kafka message queue experiment with nodejs

Queue library wrapper for widely popular queues - RabitMQ, Kafka, NSQ, NATS

Delayed Queue implementation over Kafka

Kafka Java Client for Oracle Transactional Event Queues

An embed, kafka like queue.

Pluggable server to Stream messages / events to queues like Kafka and other systems

✨ A message queue client framework (Kafka & ActiveMQ & RocketMQ)

A golang delay queue on top of all well known message queue server: nats, nats streaming, kafka.... more to come

Example of how to create your own custom serializers for Kafka queues including JSON, Smile and Kryo

Terraform code to create a Kafka message queue in AWS.

High-performance background job processing for .NET. Redis-backed queue with atomic operations, graceful shutdown, distributed locks, rate limiting, OpenTelemetry tracing, and transactional outbox pattern. Supports Kafka, RabbitMQ, and Azure Service Bus.

A small demo that leverages Spring batch's capabilities to do job processing and Apache Kafka's stream processing. A simple CSV file gets used up in a batch job which then writes it to a Kafka queue (and H2 database) for further processing.

Developed property reservation, user authentication and profile management modules of a vacation rental app using MERN stack. Implemented React-Redux where necessary. Shifted Relational data to NoSQL Database. Implemented Kafka as a Messaging Queue service. Tested performance of the application using JMeter and Mocha.

Helper for consuming Divolte events from Kafka queues and deserializing Avro records into Java objects using Avro's generated code.