{"repo":"hupe1980/krafka","free":true,"listed":false,"github":"https://github.com/hupe1980/krafka","clone":"git clone https://github.com/hupe1980/krafka.git","description":"🦀 Krafka - A pure Rust, async-native Apache Kafka client designed for high performance, safety, and ease of use.","language":"Rust","stars":19,"topics":["client","kafka","rust","redpanda"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"🦀 krafka A pure-Rust, async-native Apache Kafka client. No librdkafka, no C toolchain, no unsafe , no panics — enforced by the compiler, not by convention. Protocol parity with Apache Kafka 4.3, checked in CI against Kafka's own schemas. ✨ Why krafka Pure Rust, and it stays that way. No librdkafka, no C toolchain, no cross-compilation surprises. The optional zstd feature is the single exception, and it is opt-in. The safety posture is enforced by the compiler. unsafe code = \"deny\" crate-wide, plus panic , unwrap and expect denied across the whole crate. A malformed broker response cannot panic the process, and every allocation from untrusted input is bounded twice — by the declared count and by the bytes actually available. Protocol currency is a build failure, not a bug report. Every API version is tracked against Apache Kafka 4.3 — Fetch v18 (KIP-1166), Produce v13, Metadata v13, DescribeLogDirs v5 (KIP-1066), DescribeQuorum v2 (KIP-836/853) — and CI diffs krafka's version table against Kafka's own message schemas. ApiVersions is negotiated rather than pinned, so a 3.9 broker gets 3.9-era versions with no configuration. Correctness where it is hardest. KIP-320 truncation detection on all three legs — Fetch and ListOffsets and persisted through OffsetCommit, so it survives restarts and rebalances. KIP-447 zombie fencing with a transaction state machine that refuses the KAFKA-17754 abort-after-commit-timeout hazard. OUT OF ORDER SEQUENCE NUMBER verified head-of-line before a","default_branch":null,"files":null,"tree":[],"storefront":"/r/hupe1980","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/hupe1980/krafka/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}