Struct rdkafka_wrap::KWProducer

pub struct KWProducer {
    pub conf: KWProducerConf,
    pub producer: HpProducer<DefaultProducerContext>,
    pub admin_client: Mutex<Option<AdminClient<DefaultClientContext>>>,
}

Fields

conf: KWProducerConf

producer: HpProducer<DefaultProducerContext>

admin_client: Mutex<Option<AdminClient<DefaultClientContext>>>

Implementations

impl KWProducer

pub fn new(conf: KWProducerConf) -> KWResult<KWProducer>

pub async fn send<'a, K, P>( &'a self, record: BaseRecord<'a, K, P> ) -> Result<(), (KWError, Option<BaseRecord<'a, K, P>>)>where K: ToBytes + ?Sized, P: ToBytes + ?Sized,

Trait Implementations

impl OptionExt for KWProducer

type AdminClient = AdminClient<DefaultClientContext>

fn create_topic<'a, 'life0, 'async_trait, I>( &'life0 self, topics: I ) -> Pin<Box<dyn Future<Output = KWResult<()>> + Send + 'async_trait>>where I: IntoIterator<Item = &'a NewTopic<'a>> + Send + 'async_trait, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn get_brokers(&self) -> &str

fn get_log_level(&self) -> RDKafkaLogLevel

fn create_admin_client(&self) -> KWResult<Self::AdminClient>