public class TenantHelpers
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.util.regex.Pattern |
TENANT_PREFIX_REGEX |
Constructor and Description |
---|
TenantHelpers() |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
extractTenantPrefix(java.lang.String name) |
static boolean |
isTenantPrefixed(java.lang.String name) |
static boolean |
isTenantPrefixed(org.apache.kafka.common.TopicPartition topicPartition) |
static org.apache.kafka.common.TopicPartition |
prefixWithTenant(java.lang.String prefix,
org.apache.kafka.common.TopicPartition tp) |
public static boolean isTenantPrefixed(java.lang.String name)
public static boolean isTenantPrefixed(org.apache.kafka.common.TopicPartition topicPartition)
public static java.lang.String extractTenantPrefix(java.lang.String name)
public static org.apache.kafka.common.TopicPartition prefixWithTenant(java.lang.String prefix, org.apache.kafka.common.TopicPartition tp)