Get Started in Under 2 Minutes

Choose your deployment target and verify Kafka wire compatibility with your favorite language.

Start a Krabka Cluster

Start single-node KRaft cluster

curl -fsSL https://krabka.io/quickstart/docker-compose.yml -o docker-compose.yml
docker compose up -d

Install Operator and CRD

helm repo add krabka https://krabka-io.github.io/charts
helm repo update
helm install krabka-operator krabka/krabka-operator --namespace krabka-system --create-namespace
kubectl apply -f https://krabka.io/quickstart/krabka-cluster.yaml

Download & format cluster

curl -fsSL https://krabka.io/install.sh | bash
krabka-broker format --cluster-id krabka-local-01
krabka-broker run --config ./krabka.toml

Install with Cargo

cargo install krabka-broker krabka-cli --locked
krabka format --cluster-id krabka-dev-01
krabka-broker --node-id 1 --bind 0.0.0.0:9092

Produce and Consume Your First Records

Async FutureProducer snippet

// Add to Cargo.toml: krabka-client = "1.0"
use krabka_client::producer::{FutureProducer, ProducerRecord};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let producer = FutureProducer::builder()
        .bootstrap_servers("localhost:9092")
        .build()?;

    producer.send(
        ProducerRecord::to("quickstart-events")
            .key("user-1")
            .payload(b"Hello Krabka from Rust!"),
    ).await?;

    println!("Record successfully delivered to Krabka cluster.");
    Ok(())
}

Go client produce snippet

// go get github.com/krabka-io/krabka-streams-go
package main

import (
    "context"
    "fmt"
    "github.com/krabka-io/krabka-streams-go/client"
)

func main() {
    p, err := client.NewProducer(client.Config{
        BootstrapServers: []string{"localhost:9092"},
    })
    if err != nil { panic(err) }

    err = p.Produce(context.Background(), "quickstart-events", []byte("user-1"), []byte("Hello Krabka from Go!"))
    if err != nil { panic(err) }
    fmt.Println("Produced message to Krabka!")
}

Standard Kafka Java client

// Works unmodified with the standard Apache Kafka Java Producer!
import org.apache.kafka.clients.producer.*;
import java.util.Properties;

public class App {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        Producer<String, String> producer = new KafkaProducer<>(props);
        producer.send(new ProducerRecord<>("quickstart-events", "user-1", "Hello Krabka from Java!"));
        producer.close();
    }
}

CLI producer/consumer

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic quickstart-events
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic quickstart-events --from-beginning

Inspect Telemetry & Dashboards

The quickstart stack includes krabka-o11y and a pre-configured Grafana instance tracking real-time produce throughput, memory working set, latency histograms, and KRaft quorum state.

Dashboards / Krabka — Overview LIVE

Prometheus: Connected Last 15m • 5s refresh

Messages in (msg/s) sum(rate(kafka_server_brokertopicmetrics_messagesin_total[1m]))

54,280 msg/sec

Memory working set (RSS) container_memory_working_set_bytes

114.2 MiB / broker

Produce request latency histogram_quantile(0.99, kafka_network_requestmetrics_totaltimems)

840 µs (p99)

p50: 310 µs p95: 540 µs p99: 840 µs

Broker & Partition Health KRaft Quorum Active

0 Offline / Under-Replicated Partitions

Node-1

Active Controller

Node-2

KRaft Voter

Node-3

KRaft Voter

Live Grafana 11 instance: http://localhost:3000 (user: admin / pass: admin)

krabka-o11y-demo • Observability Docs →