risingwave_connector::source::pulsar::topic

Function get_partition_index

source
pub fn get_partition_index(topic: &str) -> ConnectorResult<Option<i32>>
Expand description

get_partition_index returns the partition index of the topic.