rdkafka
Rust wrapper for librdkafka
schema_registry_converter
Encode/decode data from/to kafka using the Confluent Schema Registry
rskafka
A minimal Rust client for Apache Kafka
kafka-protocol
Kafka wire protocol
rumqttd
high performance MQTT broker written in Rust which is light weight and embeddable
sea-streamer
🌊 The stream processing toolkit for Rust
aws-sdk-kafka
AWS SDK for Managed Streaming for Kafka
kcr_kafka_strimzi_io
Kubernetes Custom Resource Bindings
kfk
A pure Rust Kafka CLI tool for cluster management, topic operations, and message produce/consume
mq-bridge
An asynchronous message bridging library connecting Kafka, MQTT, AMQP, NATS, MongoDB, HTTP, and more
hyperi-rustlib
There's plenty of sage advice out there about how to run Rust services in production at scale — config cascades, structured logging, masking secrets, multi-backend secrets management…
tansu-sans-io
A Kafka protocol implementation using serde
samsa
Rust-native Kafka/Redpanda protocol and client implementation
kafka
Rust client for Apache Kafka
scalo
Self-regulating runtime for data-plane services -- config, logging, metrics, health, transport, backpressure, adaptive scaling. Batteries included; idiomatic Rust (also on PyPI).
aws-sdk-kafkaconnect
AWS SDK for Managed Streaming for Kafka Connect
yozefu
CLI tool for Apache kafka. It allows you to navigate topics and search Kafka records.
kafka_client
A pure Rust Kafka client library with SASL authentication support
rastreo
CLI for rastreo — enrichment-aware network discovery
tansu-model
Kafka JSON protocol definitions, bootstrapping Tansu sans I/O
krb5-gss
Pure Rust Kerberos protocol engine and krb5 GSS-API mechanism (initiator), no FFI
pilgrimage
A Kafka-like message broker in Rust
tansu
Apache Kafka compatible broker with S3, PostgreSQL, Apache Iceberg and Delta Lake
mq-bridge-app
A message queue bridge application written in Rust, designed to connect different messaging systems like RabbitMQ, Kafka, and NATS
kafka-client-protocol
Kafka protocol message types generated from Kafka specification
schemreg
Async Confluent + AWS Glue schema registry client — wire format, traits, caching, HTTP
kafkit-client
Kafka 4.0+ pure Rust client
rustfs-kafka
Rust client for Apache Kafka
crabka-security
TLS, SASL, SCRAM, OAuth, and Kerberos security utilities for Crabka
ksunami
Produce constant, configurable, cyclical waves of Kafka Records
faucet-source-kafka
Apache Kafka consumer source for the faucet-stream ecosystem
sentry_arroyo
working with streaming data
nisshi
Apache Kafka compatible broker with S3, PostgreSQL, Apache Iceberg and Delta Lake
aws-msk-iam-sasl-signer
AWS MSK IAM SASL Signer
klag-exporter
High-performance Kafka consumer group lag exporter with offset and time lag metrics
rdkafka-sys
Native bindings to the librdkafka library
tansu-storage
Storage abstraction for PostgreSQL, libSQL and ObjectStore (S3 or memory)
tansu-schema
Avro, JSON and Protocol buffer validation with conversion to Apache Iceberg, Delta Lake or Parquet via Apache Arrow
osproxy-sink
Write sink: Sink trait + OpenSearchSink now; QueueSink (Kafka) redundancy later behind the same trait
crabka-protocol
Apache Kafka wire-protocol codec (4.3.0), with typed RecordBatch and zero-copy borrowed decode
crabka-audit
Audit event model, OCSF serialization, and write pipeline for Crabka (FedRAMP 20x MLA)
crabka-schema-serde
Confluent-compatible schema serdes (Avro/Protobuf/JSON) for Crabka clients
streamling-state
State management and persistence for Streamling
rustfs-kafka-async
Async Kafka client built on tokio
kafrust
A pure Rust Kafka client with no librdkafka or C toolchain dependency
tradingview-rs
Tradingview datafeed api
tradingview-rsproject
mockforge-kafka
Kafka protocol support for MockForge
crabka-log
Byte-compatible reader/writer for Apache Kafka's on-disk log format
kafkalite-server
Broker-owned file-log Kafka wire protocol server
crabka-replicator
Cross-cluster geo-replication service for Crabka (MirrorMaker-2 equivalent)
tansu-service
Tansu protocol services and layers
prosody
Event sourcing library with persistent timers that isolates per-key failures
proto-kafka
Kafka wire protocol
crabka-schema-registry
Confluent Schema Registry-compatible REST service for Crabka (binary: crabka-schema-registry)
kacrab
A Kafka client for Rust, built from the protocol up
krafka
A pure Rust, async-native Apache Kafka client
kafko
In-process log with Kafka-like semantics: topics, partitions, offset-based reads, replay, retention
crabka-client-core
Connection management and request dispatch for Apache Kafka in Rust
crabka-rebalancer
Cruise-Control-equivalent partition rebalancer for Crabka clusters
crabka-client-admin
Operator-side admin client for Crabka clusters
kafka_wire_protocol
Generated implementation of Apache Kafka wire protocol
queuepeek
A TUI multi-broker message queue inspector for RabbitMQ, Kafka, and MQTT
crabka-throttle
Shared token-bucket throttling primitives for Crabka
crabka-operator
Kubernetes operator for Crabka clusters
crabka-broker
Single-node Apache Kafka-compatible broker (MVP)
crabka-records-legacy
Kafka v0/v1 MessageSet (legacy) codec and v2 RecordBatch bridge
crabka-connect
Connector-framework SPI (Source/Sink + converters) for Crabka
picokafka
Kafka library for tarantool-module based on librdkafka
crabka-remote-storage-topic
Topic-backed RemoteLogMetadataManager for Crabka tiered storage
crabka-authz
Shared Kafka-ACL authorization evaluator for the Crabka broker and gateway
mq-bridge-mcp
MCP Server for mq-bridge
streex
Kafka store runner
crabka-cli
Operator CLI for Crabka (binary:
crabka)
axum-webtools-dlq-redrive
Kafka DLQ redrive tool for axum web framework
streamforge
High-performance Kafka streaming toolkit with advanced filtering and transformation
crabka-grpc-gateway
gRPC / Connect-RPC + HTTP gateway into Crabka (Kafka) topics
merkql
Embedded event log with Kafka-compatible semantics and merkle tree integrity verification
schema-registry-client
Serialize/deserialize data to/from Kafka using the Confluent Schema Registry
flare-server-core
Server-side infrastructure toolkit for Flare IM services: runtime, transport, messaging, auth, telemetry, and context propagation
sea-streamer-socket
🌊 SeaStreamer backend-agnostic Socket API
madsim-rdkafka
The rdkafka simulator on madsim
crabka-bench-driver
Load driver + report aggregator for the Crabka vs Strimzi benchmark harness
tansu-client
A Service/Layer based Kafka client
sea-streamer-examples
🌊 The stream processing toolkit for Rust
crabka-compression
Kafka wire-protocol compression codecs for Rust
crabka-remote-storage
KIP-405 tiered-storage SPI (RemoteStorageManager / RemoteLogMetadataManager) and reference implementations for Crabka
qm
quick microservices in Rust
kafka-backup-core
Core engine for Kafka backup and restore operations with point-in-time recovery
crabka-client-streams
KIP-1071 Kafka Streams rebalance-protocol client for Apache Kafka in Rust
testcontainers-redpanda-rs
Unofficial redpanda test container
kcr_kafka_stackable_tech
Kubernetes Custom Resource Bindings
bevy_event_bus
A Bevy plugin that connects Bevy's event system to external message brokers like Kafka
nisshi-cli
Tansu CLI
sockudo-queue
Queue manager implementations for Sockudo
pg-tide-relay
Bidirectional relay binary for pg_tide — bridges outboxes/inboxes with NATS, Kafka, HTTP webhooks, Redis, SQS, RabbitMQ, and more
tiny_kafka
A tiny Kafka client library with producer and consumer functionalities
kcr_kafka_services_k8s_aws
Kubernetes Custom Resource Bindings
nisshi-cat
Fetch or produce (with validation when backed by a schema) messages to a topic
crabka-kraft-core
Deterministic, sans-IO KRaft consensus core (KIP-595/996) for Crabka — wasm-friendly
crabka-metadata
Versioned metadata record types + immutable image for Crabka
sockudo-adapter
Connection adapters and horizontal scaling for Sockudo
nisshi-topic
Topic administration
netring-exporters
Heavyweight anomaly exporters for netring (OTLP, Kafka) — kept out of the core crate
crabka-telemetry
Generic OTLP distributed-tracing pipeline for Crabka services
shotover
API for building custom transforms
pulse-ops
Built-in operators and combinators for Pulse dataflows — map, filter, join, window, and custom processing logic
kafkang
Rust client for Apache Kafka
crabka-raft
Metadata KRaft quorum (KIP-595 KraftController) for Crabka
sentry_usage_accountant
Sentry application uses to account for usage of shared system resources broken down by feature
crabka-connect-postgres
Postgres logical-decoding source connector for Crabka Connect
crabka-logfmt
Structured-JSON (Cloud Logging-friendly) tracing log formatter shared across Crabka services
nisshi-service
Tansu protocol services and layers
nisshi-broker
Tansu Kafka API compatible broker
flowly-kafka
reusable kafka component for flowly
rs-broker
rust broker
negrdo-standard-messaging
Standard messaging core library for Negrdo services — CloudEvents 1.0 compliant envelope management with pluggable broker adapters
tansu-auth
Tansu Auth
faucet-sink-kafka
Apache Kafka producer sink for the faucet-stream ecosystem
yozefu-app
The Kafka consumer of Yozefu
crabka-client-producer
Idempotent producer client for Apache Kafka in Rust
llm-optimizer-processor
Data processing and transformation pipeline
nisshi-proxy
A Kafka API Proxy
hermesmq-proto
Protobuf wire types for hermesmq, shared by the server and clients
outbox-kafka
Kafka transport implementation for the oxide-outbox
osproxy-kafka
Queue-backed traffic capture: serializes captured exchanges to a replay envelope and produces them through a Producer seam. The broker client composes in; this crate has no broker dependency.
crabka-voters
KIP-853 voter-set value types for Crabka (id, directory-id, endpoints, kraft.version)
pulse-io
Input/output connectors for Pulse — integrates with external systems such as Kafka, Arrow, and Parquet
crabka-client-consumer
Subscribe-style consumer client for Apache Kafka in Rust
hiver-kafka
Apache Kafka support for Hiver Framework. Hiver框架的Apache Kafka支持。 Equivalent to: Spring Kafka, Spring Cloud Stream
nisshi-client
A Service/Layer based Kafka client
rdkafka-redux
Rust wrapper for librdkafka
ds-event-stream-rs-sdk
A comprehensive Rust SDK for working with the DS Event Stream, providing high-level abstractions for producing and consuming events from Kafka
crabka-playground
WebAssembly bindings driving Crabka's deterministic KRaft consensus simulator in the browser
kincir
message streaming library inspired by Watermill
faucet-common-kafka
Shared configuration types for the faucet-stream Kafka source and sink connectors
quarb-kafka
Apache Kafka adapter for the Quarb query engine
yozefu-wasm-types
Types and structures for defining WebAssembly modules
flare-core-messaging
Event bus and MQ primitives for Flare server applications, including NATS and Kafka support
oxigdal-kafka
Apache Kafka integration for OxiGDAL - async producer/consumer with schema registry and transactions
camel-component-kafka
Kafka component for rust-camel integration framework
datum-mq
Native Kafka sources and sinks for Datum streams
varpulis-connectors
Connector implementations for Varpulis (MQTT, Kafka, NATS, HTTP, etc.)
kafka-remapper-core
Core library for Kafka partition remapping proxy
kommitted
Measure Kafka Consumer Offset Lag and Time Lag
tansu-cat
Fetch or produce (with validation when backed by a schema) messages to a topic
tansu-topic
Topic administration
lnmp-transport
Transport bindings for LNMP protocol (HTTP, Kafka, gRPC)
lnc-client
LANCE client library - Rust client for the LANCE streaming platform
pulse-state
State management utilities for Pulse — provides windowing, aggregations, and persistent operator state
kyu-copy
Bulk data import for KyuGraph: CSV, Parquet, Arrow IPC, and Kafka readers
xdl-database
Database connectivity module for XDL - supports PostgreSQL, MySQL, DuckDB, SQLite, ODBC, Redis, and more
sea-streamer-kafka
🌊 SeaStreamer Kafka / Redpanda Backend
winterbaume-kafka
Amazon MSK service implementation for winterbaume
reinhardt-streaming
Backend-agnostic streaming abstraction with Kafka support
spring-stream
Integrate sea-streamer with spring-rs
osproxy-capture
The traffic-capture seam: a Capture trait an external recorder (e.g. a Kafka writer) implements, with composable redaction. No broker dependency.
tansu-cli
Tansu CLI
crab-kafka
Forward <TCP|UDP> + TLS traffic to kafka
hermesmqd
hermesmq server daemon: a Raft-replicated message queue
varpulis-connector-kafka
Kafka connector for Varpulis CEP engine
oxirs-stream
Real-time streaming support with Kafka/NATS/MQTT/OPC-UA I/O, RDF Patch, and SPARQL Update delta
miffy
shadow-testing proxy: Send requests to a "reference" implementation, send the request to a "candidate" implementation, always respond with the "reference" implementation and log/publish…
pulse-core
Core runtime and dataflow engine for Pulse — defines execution graph, operators, and streaming primitives
tansu-broker
Tansu Kafka API compatible broker
rastreo-server
HTTP control plane for rastreo — enrichment-aware network discovery
snakeice-rdkafka
Rust wrapper for librdkafka
streamling-e2e
End-to-end tests for streamling
easy-config-def
defining and validating application configurations, inspired by Apache Kafka's ConfigDef
tansu-proxy
A Kafka API Proxy
rivven-schema
Schema Registry for Rivven - Confluent-compatible schema management
llingr-nexus
Contracts for the llingr Rust message-processing ecosystem: message, traits, metrics, handler traits
rdkafka-autoschematic-fork
Rust wrapper for librdkafka
evoxy-bridge
The async fan-out bridge (ADR-005): turns an Envoy-mirrored request into a Kafka record over osproxy's Producer seam. A separate deployment artifact, not the Envoy extension.
tinyflow-api
Core traits, types, and abstractions for Tinyflow streaming framework
clamber-web-core
clamber web core
summer-stream
Integrate sea-streamer with summer-rs
crabka-ids
Canonical newtypes for Crabka's cross-crate Kafka identifiers (offset, partition index, …)
kafrust-protocol
Kafka wire protocol primitives for kafrust
br-cache
Cache and Message Queue abstraction layer
kafka-api
Manual implementation of Apache Kafka API in Rust
nisshi-generator
Generate fake data for schema backed topics
mlua-rdkafka
Mlua support for rdkafka
kacrab-protocol
Kafka wire protocol types — generated from upstream message schemas by
kacrab-codegen
katla
data flow generator
warpin-event-bus
Generic async event bus abstraction with Kafka and no-op backends
fakecloud-kafka
Amazon MSK (Managed Streaming for Apache Kafka, kafka) implementation for FakeCloud
yozefu-lib
Core library of yozefu
qm-kafka
Kafka helper functions
rmqtt-bridge-egress-kafka
Bridge remote KAFKA in egress mode
nisshi-auth
Tansu Auth
llm-analytics-hub
Enterprise-grade analytics hub for LLM ecosystem monitoring with Kafka, TimescaleDB, Redis, and Kubernetes orchestration
gcn-kafka
Kafka client for NASA's General Coordinates Network (GCN)
rumqttlog
kafka inspired rumqtt's mqtt commitlog
osproxy-kafka-krafka
Portable, pure-Rust Kafka Producer for osproxy-kafka over krafka + rustls. The TLS crypto provider is build-selected (ring for non-fips, the validated aws-lc-rs FIPS module for fips)…
kafcat
cat but with kafka
caudal-sdk
Caudal SDK - Event observability for distributed systems
qm-utils
functions and macros
qm-s3
S3 helper functions
rusoto_kafka
AWS SDK for Rust - Managed Streaming for Kafka @ 2018-11-14
schema_registry_converter_sf
just a fork of the original schema_registry_converter crate with a fix for the avro serialization
rskafka_wasi
A minimal Rust client for Apache Kafka
tansu-generator
Generate fake data for schema backed topics
kcli
A Kafka client CLI tool for debugging and inspecting Kafka clusters
kafka-http
Kafka HTTP client to allow a rust native way to interact with the restful kafka HTTP proxy
rmqtt-bridge-ingress-kafka
Bridge remote KAFKA in ingress mode
talos_rdkafka_utils
RD Kafka utilities used in Talos
mlua-kafka
An rdkafka-based implementation of LuaRocks chensoft/kafka for mlua
tansu-perf
Performance producer/consumer
br-kafka
kafka queue
ene_kafka
Ene Kafka is an easy-to-use Rust client for Apache Kafka
tansu-otel
Tansu OTEL common configuration
drasi-source-kafka
Kafka source plugin for Drasi
redpanda-transform-sdk
authoring Redpanda Data Transforms
sprue
Streaming and message queue client CLI for Kafka, NATS, and Redis Streams. Part of the rustpunk portfolio.
fluxmq
High-performance message broker and streaming platform inspired by Apache Kafka
llm-optimizer-collector
Metrics and data collection from LLM systems
seesaw-kafka
Kafka backend for Seesaw event-driven orchestration
kafka-threadpool
An async rust threadpool for publishing messages to kafka using SSL (mTLS) or PLAINTEXT protocols
merkql-notify
Notification trait and types for merkql event streaming
prometheus-extensions
Prometheus extensions: AggregateCounter (per-label + total metrics), scientific-notation encoder, and EMA sensor
yozefu-tui
rendering the TUI of Yozefu
event-notification
A modular event notification system with multi-channel support
konsumer_offsets
parse the content of the Kafka
__consumer_offsetsinternal topic
merkql-notify-sqs
AWS SQS notification plugin for merkql
merkql-notify-sns
AWS SNS notification plugin for merkql
rust_kafka_like
A Kafka-like message broker in Rust
krishiv-api
Krishiv — hybrid batch and streaming compute engine
franz
friendly, and blazingly fast alternative to Apache Kafka
jedisct1/flowgger
fast, simple and lightweight data collector
high-level-kafka
High Level Kafka client for Rust
streambed
core library components
unis-kafka
unis框架的Kafka实现。
rill-core-actor
Actor model infrastructure for the Rill ecosystem
rsflow
High-performance Rust flow processing engine
kafka-replicator
Application for replication data between kafka clusters
streambed-logged
Logged is a small library that implements a file-system-based commit log
arkflow
High-performance Rust flow processing engine
kawadb-broker
High-performance Kafka-compatible message broker
krishiv-runtime
Krishiv — hybrid batch and streaming compute engine
kmailbox
kafka mailbox
eventuary-kafka
Apache Kafka event backend for eventuary
merkql-notify-webhook
HTTP webhook notification plugin for merkql
armature-messaging
Message broker integrations for the Armature framework - RabbitMQ, Kafka, NATS, and AWS SQS/SNS
Try searching with DuckDuckGo.