ruststream-rdkafka

Apache Kafka broker implementation for the RustStream messaging framework, backed by rdkafka / librdkafka: consumer groups as subscription descriptors, auto or tracked commit modes, native record keys for per-key ordering, and raw librdkafka config passthrough everywhere.

Guides and examples: https://powersemmi.github.io/ruststream-rdkafka/.

Testing

The testing feature ships an in-process test broker (KafkaTestBroker) for application tests with the core TestApp harness:

[dev-dependencies]
ruststream-rdkafka = { version = "0.5", features = ["testing"] }

Never enable this feature in production builds.