Struct KafkaAdapter 

pub struct KafkaAdapter { /* private fields */ }

Kafka transport adapter stub (without kafka feature).

This is a stub implementation for development and testing. Enable the kafka feature for actual Kafka delivery.

Implementations

impl KafkaAdapter

pub fn new(config: KafkaConfig) -> Result<Self, SubscriptionError>

Create a new Kafka adapter stub.

Note

This is a stub implementation. Enable the kafka feature for actual delivery.

Errors

This stub implementation never fails, but returns Result for API compatibility.

Trait Implementations

impl Debug for KafkaAdapter

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

Formats the value using the given formatter.

impl TransportAdapter for KafkaAdapter

fn deliver<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, event: &'life1 SubscriptionEvent, subscription_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), SubscriptionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Deliver an event to the transport.

fn name(&self) -> &'static str

Get the adapter name for logging/metrics.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check if the adapter is healthy/connected.