Struct KafkaTestBroker 

pub struct KafkaTestBroker { /* private fields */ }

In-process broker for application tests: same descriptors, no Kafka cluster.

Clones share one router, so a publisher and a subscriber cloned from the same broker see each other; separate new calls are fully isolated.

Examples

use ruststream::{Broker, OutgoingMessage, Publisher, Subscriber};
use ruststream_rdkafka::testing::KafkaTestBroker;
let broker = KafkaTestBroker::new();
let mut subscriber = broker.subscribe("orders").await?;
broker.publisher().publish(OutgoingMessage::new("orders", b"{}")).await?;

Implementations

impl KafkaTestBroker

pub fn new() -> Self

Creates an isolated in-process broker.

pub async fn subscribe( &self, topic: impl Into<String>, ) -> Result<KafkaTestSubscriber, KafkaError>

Subscribes to topic (exact-name routing; no groups or partitions in-process).

Errors

Returns KafkaError::InvalidOptions when topic is empty or a ^ pattern.

pub async fn subscribe_topics( &self, topics: &[String], ) -> Result<KafkaTestSubscriber, KafkaError>

Subscribes to several topics as one subscription, mirroring KafkaTopic::and_topic: every name routes exactly.

Errors

Returns KafkaError::InvalidOptions when a name is empty, or when a name is a ^ pattern: the in-process broker routes by exact topic name, so pattern subscriptions need a real cluster.

pub fn publisher(&self) -> KafkaTestPublisher

A publisher into this broker’s router.

Trait Implementations

impl Broker for KafkaTestBroker

type Error = KafkaError

The error type returned by broker-level operations.

async fn connect(&self) -> Result<(), Self::Error>

Establishes the connection to the broker. Idempotent: calling multiple times must not open additional sockets.

async fn shutdown(&self) -> Result<(), Self::Error>

Closes the broker connection, flushing in-flight publishes and stopping background tasks.

impl Clone for KafkaTestBroker

fn clone(&self) -> KafkaTestBroker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KafkaTestBroker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for KafkaTestBroker

fn default() -> KafkaTestBroker

Returns the “default value” for a type.

impl DescribeServer for KafkaTestBroker

fn describe_server(&self) -> ServerSpec

Returns the server coordinates for this broker.

impl Subscribe for KafkaTestBroker

type Subscriber = KafkaTestSubscriber

The subscriber type opened by a by-name subscription.

async fn subscribe(&self, name: &str) -> Result<Self::Subscriber, Self::Error>

Opens a subscription to name, producing this broker’s Subscriber.

impl SubscriptionSource<KafkaTestBroker> for KafkaTopic

Available on crate feature testing only.

type Subscriber = KafkaTestSubscriber

The subscriber type this source opens.

fn name(&self) -> &str

The name (subject / channel) this subscription binds to.

async fn subscribe( self, broker: &KafkaTestBroker, ) -> Result<Self::Subscriber, KafkaError>

Opens the subscription against broker. Called once, after Broker::connect.

impl TestableBroker for KafkaTestBroker

fn install_coordinator(&self, coordinator: Coordinator)

Installs the harness coordinator into this broker’s bus for a test run. Idempotent: a second install on the same broker is ignored.

fn inject(&self, message: OutgoingMessage<'_>)

Injects a message onto the bus as an external producer would, synchronously (no awaiting). Routes through the broker’s normal fanout, so it is recorded and counted like any publish.

fn published(&self, name: &str) -> Vec<RawMessage>

Returns every message published to name on this broker, in publish order. Backs the harness’s published::<T>(name) assertions and expect_published.