kafka-backup-core cargo 0.23.3 clean Core engine for Kafka backup and restore operations with point-in-time recovery 1.4K 5h ago rustfs-kafka cargo 1.4.0 clean Rust client for Apache Kafka 77K 11h ago rustfs-kafka-async cargo 1.4.0 clean Async Kafka client built on tokio 77K 11h ago fakecloud-kafka cargo 0.49.0 clean Amazon MSK (Managed Streaming for Apache Kafka, kafka) implementation for FakeCloud 755 2d ago mercury-minimalist-kafka cargo 4.12.21 clean Opt-in Kafka building blocks for Mercury: publish events to topics (simple.kafka.notification) and route topics into Event Script flows, with externalized… 80 1d ago taskcraft-kafka cargo 0.2.0 clean Kafka source for taskcraft: offsets committed by the commit boundary, ids from message keys, metadata from headers 15 13h ago ecat-mq-kafka cargo 4.0.0 clean Kafka message queue backend for e-cat 12 1d ago krafka cargo 0.26.0 clean A pure Rust, async-native Apache Kafka client 20K 2d ago reinhardt-streaming cargo 0.4.0-alpha.20 clean Backend-agnostic streaming abstraction with Kafka support 3.9K 1d ago crabka-compression cargo 0.4.1 clean Kafka wire-protocol compression codecs for Rust 2.5K 1d ago sz-orm-queue cargo 9.4.0 clean SZ-ORM Message Queue Extension - 6 MQ Providers (RabbitMQ/NATS/Pulsar/Kafka/ActiveMQ real, RocketMQ stub) 2.5K 1d ago crabka-protocol cargo 0.4.1 clean Apache Kafka wire-protocol codec (4.3.0), with typed RecordBatch and zero-copy borrowed decode 2.4K 1d ago crabka-security cargo 0.4.1 clean TLS, SASL, SCRAM, OAuth, and Kerberos security utilities for Crabka 2.3K 1d ago crabka-client-core cargo 0.4.1 clean Connection management and request dispatch for Apache Kafka in Rust 2.0K 1d ago crabka-client-consumer cargo 0.4.1 clean Subscribe-style consumer client for Apache Kafka in Rust 1.7K 1d ago crabka-client-admin cargo 0.4.1 clean Operator-side admin client for Crabka clusters 1.7K 1d ago crabka-metadata cargo 0.4.1 clean Versioned metadata record types + immutable image for Crabka 1.7K 1d ago crabka-client-producer cargo 0.4.1 clean Idempotent producer client for Apache Kafka in Rust 1.7K 1d ago crabka-log cargo 0.4.1 clean Byte-compatible reader/writer for Apache Kafka's on-disk log format 1.5K 1d ago crabka-voters cargo 0.4.1 clean KIP-853 voter-set value types for Crabka (id, directory-id, endpoints, kraft.version) 1.4K 1d ago scalo cargo 2.14.1 clean An integrated runtime for at scale data plane services. Attach and 'enterprise-up' your application. 1.3K 2d ago crabka-schema-serde cargo 0.4.1 clean Confluent-compatible schema serdes (Avro/Protobuf/JSON) for Crabka clients 1.3K 1d ago crabka-authz cargo 0.3.9 clean Shared Kafka-ACL authorization evaluator for the Crabka broker and gateway 1.2K 1d ago crabka-remote-storage cargo 0.3.9 clean KIP-405 tiered-storage SPI (RemoteStorageManager / RemoteLogMetadataManager) and reference implementations for Crabka 1.2K 1d ago crabka-telemetry cargo 0.3.9 clean Generic OTLP distributed-tracing pipeline for Crabka services 1.1K 1d ago crabka-remote-storage-topic cargo 0.3.9 clean Topic-backed RemoteLogMetadataManager for Crabka tiered storage 1.1K 1d ago crabka-raft cargo 0.3.9 clean Metadata KRaft quorum (KIP-595 KraftController) for Crabka 1.1K 1d ago crabka-records-legacy cargo 0.3.9 clean Kafka v0/v1 MessageSet (legacy) codec and v2 RecordBatch bridge 1.1K 1d ago crabka-broker cargo 0.3.9 clean Single-node Apache Kafka-compatible broker (MVP) 1.1K 1d ago crabka-logfmt cargo 0.3.9 clean Structured-JSON (Cloud Logging-friendly) tracing log formatter shared across Crabka services 998 1d ago 