pub(super) fn get_kafka_topic( props: &BTreeMap<String, String>, ) -> ConnectorResult<&String>
Get the Kafka topic name.