Crate kacrab 

kacrab

A Kafka client for Rust, built from the protocol up.

This is the public entry point users depend on. The current runtime surface is:

• common: shared Kafka domain types (TopicPartition, offsets, group metadata).
• config: Java-style config facade, typed configs, metadata, and validation.
• wire: TCP/TLS/SASL sessions, ApiVersions, metadata, and request dispatch.
• producer: batching, routing, idempotence, transactions, and delivery handles.
• consumer: the Apache Kafka 4.3.0 Consumer surface (subscribe/assign, group rebalancing, fetching, offset commits, and interceptors).
• admin: the full Apache Kafka 4.3.0 Admin operation surface (topics, configs, groups, offsets, transactions, ACLs, quotas, tokens, and more).

The companion crate kacrab-macros provides procedural macros.

Modules

admin

Admin API for managing topics, partitions, and configs.

common

Shared Kafka-compatible domain types used across clients.

config

Configuration metadata and Java-style property interoperability.

consumer

Kafka consumer client (consumer feature).

producer

Producer API built on top of the wire/session layer.

wire

Runtime Kafka wire/session support.

Macros

kafka_config

Declares a Kafka client config schema and generates a typed struct, builder, key constants, and static config metadata.