oxirs-stream 0.2.2

//! Apache Kafka backend module
//!
//! This module provides comprehensive Kafka integration for OxiRS streaming,
//! organized into specialized sub-modules for better maintainability.

pub mod backend;
pub mod config;
pub mod message;

// Re-export commonly used types
pub use backend::{
    ConsumerId, ConsumerMetrics, KafkaBackend, MessageCallback, PartitionAssignment,
};
pub use config::{
    KafkaAcks, KafkaCompressionType, KafkaProducerConfig, KafkaProducerStats, KafkaSecurityConfig,
    PartitionStrategy, SaslConfig, SaslMechanism, SchemaRegistryConfig, SecurityProtocol,
    SslConfig,
};
pub use message::KafkaEvent;

// Type alias for producer (KafkaBackend acts as the producer)
pub type KafkaProducer = KafkaBackend;

// Type alias for consumer (KafkaBackend acts as the consumer manager)
pub type KafkaConsumer = KafkaBackend;