public class TenantHelpers extends Object
Modifier and Type | Field and Description |
---|---|
static Function<String,String> |
NAME_TO_NULL_CALLBACK |
static Function<String,String> |
NAME_TO_TENANT_CALLBACK |
static Pattern |
TENANT_PREFIX_REGEX |
Constructor and Description |
---|
TenantHelpers() |
Modifier and Type | Method and Description |
---|---|
static String |
extractLogicalName(String name) |
static String |
extractTenantPrefix(String name) |
static String |
extractTenantPrefix(String name,
boolean includeDelimiter) |
static boolean |
isTenantPrefixed(String name) |
static boolean |
isTenantPrefixed(org.apache.kafka.common.TopicPartition topicPartition) |
static org.apache.kafka.common.TopicPartition |
prefixWithTenant(String prefix,
org.apache.kafka.common.TopicPartition tp) |
public static final Pattern TENANT_PREFIX_REGEX
public static boolean isTenantPrefixed(String name)
public static boolean isTenantPrefixed(org.apache.kafka.common.TopicPartition topicPartition)
public static org.apache.kafka.common.TopicPartition prefixWithTenant(String prefix, org.apache.kafka.common.TopicPartition tp)