Function get_kafka_topic

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

get kafka topic name