Function rlink_connector_kafka::create_input_format

pub fn create_input_format(
    conf_map: HashMap<String, String>, 
    topics: Vec<String>, 
    buffer_size: Option<usize>, 
    deserializer_builder: Option<Box<dyn KafkaRecordDeserializerBuilder>>
) -> KafkaInputFormat