#kafka

Apache Camel Kamelets Repository

High-performance open-source in-memory graph database for GraphRAG, AI memory, agentic AI, and real-time graph analytics. Cypher-compatible, built in C++.

Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.

Automated documentation for event-driven applications built with Spring Boot

Framework for automated integration tests with focus on message-based applications

Confluent Schema Registry for Kafka

Standalone Karafka library for producing Kafka messages

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

Klaw, the latest OS tool by Aiven, helps enterprises cope with Apache Kafka(r) topics, schema registry and connectors governance by introducing roles/authorizations to users of various teams of an org.

asyncio client for kafka

Library for handing Kafka messages with retries

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

Snowflake Kafka Connector (Sink Connector)

The Open source Resource as Code framework for Apache Kafka. Jikkou helps you implement GitOps for Kafka at scale!

Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.

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

Confluent's Kafka Python Client combined with Django

Conduktor CLI to perform operations directly from your command line or a CI/CD pipeline

The Apache Kafka C/C++ library

70 independent Go packages for backend services: retry and exponential backoff, HTTP client and server, OpenTelemetry and Prometheus metrics, Argon2id password hashing, JWT, Redis and Valkey, Kafka, AWS S3 and SQS, SQL helpers, caching, and log redaction.

Open-source API mock server for REST, gRPC, GraphQL, WebSocket, Kafka, MQTT and more

CSharp SDK for CloudEvents

Command Line Tool for managing Apache Kafka

Cloud Queues with Task and Messages and Multiple Providers

OAuth2 support for Apache Kafka® to work with many OAuth2 authorization servers

Taking the Java out of Kafka

Model Context Protocol server for Aiven

Kafka input and output plugin for Fluentd

Library which provides helpers for easier Karafka consumers tests

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 🚀