Skip to main content

API Reference Directory

Compiler-generated reference trees for the broker, clients, tools, and streams libraries, in each language's native documentation format, all served under krabka.io. The schema registry, gres, and observability repositories do not publish one yet.

Broker Engine

Byte-exact Kafka wire broker, KRaft consensus quorum, tiered storage, and every crate in the broker workspace.

Rustdoc Rust v1.1.5
Wire Protocol

Kafka wire-protocol records, compression, ids, metadata, security, and units shared by the broker and the clients.

Rustdoc Rust v0.7.0
Rust Client

Async producer, consumer, admin, and coordination clients over one broker connection pool.

Rustdoc Rust v0.7.1
Rust Streams

KIP-1071 streams-group client with a typed Processor API, KStream and KTable DSL, and interactive queries.

Rustdoc Rust main
Command-Line Tools

The krabka command and its plugin crates for administration, backup, barriers, and guard.

Rustdoc Rust v0.4.6
Connect

Connect worker and connector crates, including the PostgreSQL change-data-capture source.

Rustdoc Rust v0.4.1
Kubernetes Operator

Custom resource definitions and reconcilers for clusters, node pools, topics, users, connectors, and rebalances.

Rustdoc Rust v1.0.2
Rebalancer

Partition rebalancing goals and the Connect-RPC service that answers KafkaRebalance requests.

Rustdoc Rust v0.4.5
gRPC Gateway

Kafka gRPC gateway, the application SDK crate, and the SDK conformance harness.

Rustdoc Rust v0.5.0
Java Streams & Arrow

Kafka Streams 4.x API, Apache Arrow columnar batches, Schema Registry serdes, and coordination primitives.

Javadoc Java v1.4.2
Go Streams & Arrow

Go stream client with Arrow record batching, barrier cuts, schema decoding, and coordination.

Godoc Go v0.2.0

Each repository generates its reference from source docstrings (Rustdoc, Javadoc, or Godoc) and publishes it to https://krabka.io/<repository>/.

For architectural overviews, memory management specifications, and runnable tutorials, consult the Documentation Hub.