ruststream_rdkafka/testing/mod.rs
1//! In-process test broker, behind the `testing` feature.
2//!
3//! [`KafkaTestBroker`] implements the core `TestableBroker` contract over an in-memory router
4//! so application handlers wired against Kafka descriptors can be exercised without a cluster:
5//! messages fan out synchronously to subscribers matched by exact topic name.
6//!
7//! Scope: topic-name routing, settlement, headers, and the partition-key header. Consumer
8//! groups, partitions, committed offsets, start offsets, and rebalancing are transport
9//! behavior; exercise them against a real cluster (see the crate's integration tests and
10//! `KAFKA_TEST_URL`).
11
12mod broker;
13mod publisher;
14mod router;
15mod subscriber;
16
17pub use broker::KafkaTestBroker;
18pub use publisher::KafkaTestPublisher;
19pub use subscriber::{KafkaTestMessage, KafkaTestSubscriber};