#kafka

Kafka Pub/Sub for the Watermill project.

Rate limitor written in Go for HTTP requests according to a configurable set of regex patterns

ksqlDb.RestApi.Client is a C# LINQ-enabled client API for issuing and consuming ksqlDB push and pull queries and executing statements.

Go SDK to scaffold, run, and scale event-driven backends from zero. YAML-driven with Fiber, PostgreSQL, NATS JetStream, and Kafka.

CLI kafka client

该仓库未发布描述。

A production-grade messaging abstraction for Go. It provides a unified API to decouple business logic from various brokers including Kafka, RabbitMQ, RocketMQ, NATS, Redis, and AWS SQS. Featuring built-in OpenTelemetry integration and engineered for high reliability.

Dalmarkit is an opinionated .NET utility library that simplifies the building of AWS Cognito secured JSON REST APIs with audit trails using ASP.NET Core and Entity Framework Core with PostgreSQL.

A Broadway connector for Kafka

该仓库未发布描述。

Sub-millisecond AI fraud detection at enterprise scale. Engineered for high-throughput predictability.

Rust Redpanda Testcontainer

Production-ready marketplace backend — Go · gRPC · PostgreSQL 18 · PASETO · Clean Architecture · Docker

An efficient and scalable library for stateless Kafka message processing written in Go

PgOutput2Json is a lightweight .NET library that uses PostgreSQL logical replication to stream row-level changes as JSON messages to RabbitMQ, Kafka, Redis, or your own .NET Core application.

Java生态研究(Spring Boot + Redis + Dubbo + RocketMQ + Elasticsearch)🔥🔥🔥🔥🔥

Kafka bundle for Symfony

In-memory indexed cache library for Java 21. Fluent DSL, lock-free reads, pluggable sync (Kafka, HTTP, DB), leader election, and snapshot persistence.

Simple Kafka transport for Symfony Messenger.

High-performance, API-compatible drop-in replacement for Confluent Schema Registry. Avro, Protobuf & JSON Schema with PostgreSQL, MySQL, Cassandra storage. Built-in RBAC, client side field encryption, data contracts, audit logging. No Kafka dependency. Apache 2.0.

Lenses.io CLI (command-line interface)

🧰 Testcontainers Extensions with advanced testing capabilities.

A convenient Elixir library to work with Avro messages, schemas and Confluent® Schema Registry

🚀 Eventstream pipeline to preprocess and resend from some source to some storage

yuanboot

kratos transport layer extension, support: rabbitmq,kafka,rocketmq,activemq,apollo,mcp,tcp,websocket...

A .Net toolkit for interactions with common technologies.