#kafka

asyncio client for kafka

Confluent's Apache Kafka .NET client

Confluent Schema Registry for Kafka

Standalone Karafka library for producing Kafka messages

Communication infrastructure for the AI era — one binary, one broker, one storage layer, any protocol

Snowflake Kafka Connector (Sink Connector)

franz-go is a feature complete, pure Go library for Kafka from 0.8.0 through 4.2+. Producing, consuming, transacting, administrating, etc.

Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern

Cloud Queues with Task and Messages and Multiple Providers

Library which provides helpers for easier Karafka consumers tests

Taking the Java out of Kafka

Java SDK for CloudEvents

Library for handing Kafka messages with retries

The type-safe, event-driven workflow orchestration library that scales with your business. Build robust, distributed workflows in Go with compile-time safety, automatic retries, and horizontal scaling out of the box. Integrate with your existing tech stack using adapters 🚀

Your API mocking tool for OpenAPI and AsyncAPI using Go and JavaScript - https://mokapi.io

Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.

Model Context Protocol server for Aiven

Kafka input and output plugin for Fluentd

Modern Reactive CQRS Architecture Microservice development framework based on DDD and EventSourcing | 基于 DDD & EventSourcing 的现代响应式 CQRS 架构微服务开发框架

Your one stop boilerplate killer for any standard!

Domain-aware infrastructure health checks in one Go binary — TLS expiry, HTTP, DNS, NATS, Kafka, PostgreSQL, Consul, HAProxy and 20+ more. No agents, no server.

Moro is a high-performance, type-safe API framework with intelligent routing and multi-runtime support (Node, Edge, Lambda, Workers).

Confluent's Kafka Python Client combined with Django

Event sourcing journal implementation using Kafka as main storage

A crate to convert bytes to something more useable and the other way around in a way Compatible with the Confluent Schema Registry. Supporting Avro, Protobuf, Json schema, and both async and blocking.

Stateful actors on Apache Flink 2.x and Java 21 — durable per-key state, exactly-once messaging, Kafka and Kinesis I/O, Kubernetes-native deployment. Continues the Apache Stateful Functions programming model on the modern Flink line.