Function rlink_connector_kafka::create_output_format[][src]

pub fn create_output_format(
    conf_map: HashMap<String, String>,
    topic: Option<String>,
    buffer_size: Option<usize>
) -> KafkaOutputFormat