risingwave_connector::parser::util

Function get_kafka_topic

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

get kafka topic name