Trait rlink_connector_kafka::source::deserializer::KafkaRecordDeserializerBuilder

pub trait KafkaRecordDeserializerBuilder {
    fn build(&self) -> Box<dyn KafkaRecordDeserializer>;
}

Required methods

fn build(&self) -> Box<dyn KafkaRecordDeserializer>

Loading content...

Implementors

impl<T> KafkaRecordDeserializerBuilder for DefaultKafkaRecordDeserializerBuilder<T> where
    T: Default + KafkaRecordDeserializer + 'static, 

fn build(&self) -> Box<dyn KafkaRecordDeserializer>

Loading content...