Module topic

risingwave_connector::source::pulsar

Module topic 

Source

Structs§

Topic
ParsedTopic is a parsed topic name, Generated by parse_topic.

Constants§

DEFAULT_NAMESPACE 🔒
NON_PERSISTENT_DOMAIN 🔒
PARTITIONED_TOPIC_SUFFIX 🔒
PERSISTENT_DOMAIN 🔒
PUBLIC_TENANT 🔒

Functions§

check_topic_exists 🔒
get_partition_index
get_partition_index returns the partition index of the topic.
parse_topic
parse_topic parses a topic name into its components. The short topic name can be: