Skip to main content

parse_partitioned_topic

Function parse_partitioned_topic 

Source
pub fn parse_partitioned_topic(topic: &str) -> ConnectorResult<Topic>
Expand description

Returns the partitioned topic, i.e. the topic without partition suffix, as schemas are shared by all partitions.