Trait cloudevents_sdk_rdkafka::FutureRecordExt

pub trait FutureRecordExt<'a, K: ToBytes + ?Sized>: Sealed {
    fn message_record(
        self, 
        message_record: &'a MessageRecord
    ) -> FutureRecord<'a, K, Vec<u8>>;
}

Extension Trait for FutureRecord that fills the record with a MessageRecord.

This trait is sealed and cannot be implemented for types outside of this crate.

Required methods

fn message_record(
    self,
    message_record: &'a MessageRecord
) -> FutureRecord<'a, K, Vec<u8>>

Fill this FutureRecord with a MessageRecord.

Loading content...

Implementations on Foreign Types

impl<'a, K: ToBytes + ?Sized> FutureRecordExt<'a, K> for FutureRecord<'a, K, Vec<u8>>

fn message_record(
    self,
    message_record: &'a MessageRecord
) -> FutureRecord<'a, K, Vec<u8>>

Loading content...

Implementors

Loading content...