Every code sample compiles against the current release. Start with Getting Started, then the guide for your client. For a specific problem, see Configuration and Error Handling. From 0.26 or earlier: Upgrading to 0.27. From rdkafka: Migrating from rdkafka.
Install krafka, connect, and produce and consume your first records.
Task-oriented recipes for common Kafka application patterns.
Every connection, producer, consumer, admin and transport option, with their defaults.
Every breaking change in krafka 0.27 with the old API, the new API and what to do: the Kafka handle, send/enqueue, recv, metrics.
Move an rdkafka application to krafka: librdkafka properties mapped to builder settings, and FutureProducer and StreamConsumer equivalents.
Batching, compression, partitioning, idempotence and exactly-once transactions.
Consumer groups, cooperative and eager rebalancing, offset management and KIP-848.
Queue-like consumption with KIP-932 share groups: per-record acknowledgement without partition ownership.
Topics, partitions, configs, ACLs, quotas, consumer groups, delegation tokens and cluster features.
TLS, mTLS, SASL PLAIN, SCRAM, OAUTHBEARER and the built-in OIDC token provider.
Connection recipes for Azure Event Hubs, Google Managed Kafka, Amazon MSK and Confluent Cloud, compiled against the current API.
Producer and consumer hooks for tracing, redaction, auditing and record rewriting.
Each client's metrics snapshot, the Prometheus text format, the spans krafka emits, and KIP-714 client telemetry.
What krafka optimises by default, which settings move throughput, and how to measure.
Test your Kafka code against an in-process fake broker with injected faults, or against a real broker in a container.
Error taxonomy, which errors are retriable, and how to build a dead-letter path.
Supported Kafka APIs and versions, negotiation, and how parity with Apache Kafka is enforced in CI.
Module boundaries, the connection pool, the record accumulator and the concurrency model.
Who maintains krafka, which versions are supported, how to report a vulnerability, and the checks every change passes.
