Function GetTopicFromTable

utils/kafka.go:23–29

GetTopicFromTable get the topic name for namespace and table name

(namespace, table, suffix string)

// GetTopicFromTable get the topic name for namespace and table name
func GetTopicFromTable(namespace, table, suffix string) string {
	if suffix == "" {
		return fmt.Sprintf("%s-%s-%s", aresRedologKafkaTopicPrefix, namespace, table)
	} else {
		return fmt.Sprintf("%s-%s-%s-%s", aresRedologKafkaTopicPrefix, namespace, table, suffix)
	}
}