risingwave_connector::parser::utils

Function get_kafka_topic

Source 
pub(super) fn get_kafka_topic(
    props: &BTreeMap<String, String>,
) -> ConnectorResult<&String>
Expand description

get kafka topic name