public class TenantContext extends java.lang.Object implements TransformContext
Modifier and Type | Class and Description |
---|---|
static class |
TenantContext.ValueType |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DELIMITER |
protected int |
prefixSizeInBytes |
MultiTenantPrincipal |
principal |
Constructor and Description |
---|
TenantContext(MultiTenantPrincipal principal) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
addTenantPrefix(java.lang.String value) |
static java.lang.String |
extractTenant(java.lang.String prefixedName) |
static java.lang.String |
extractTenantPrefix(java.lang.String prefixedName) |
boolean |
hasTenantPrefix(java.lang.String value) |
static boolean |
hasTenantPrefix(java.lang.String prefix,
java.lang.String prefixedName) |
static boolean |
isTenantPrefixed(java.lang.String prefixedName) |
java.lang.String |
prefix() |
java.lang.String |
prefixedWildcard() |
int |
prefixSizeInBytes() |
java.lang.String |
removeAllTenantPrefixes(java.lang.String message) |
static java.lang.String |
removePrefix(java.lang.String value) |
java.lang.String |
removeTenantPrefix(java.lang.String value) |
org.apache.kafka.common.TopicPartition |
removeTenantPrefix(org.apache.kafka.common.TopicPartition tp) |
int |
sizeOfRemovedPrefixes(java.lang.String message) |
public static final java.lang.String DELIMITER
public final MultiTenantPrincipal principal
protected final int prefixSizeInBytes
public TenantContext(MultiTenantPrincipal principal)
public static boolean isTenantPrefixed(java.lang.String prefixedName)
public static java.lang.String extractTenantPrefix(java.lang.String prefixedName)
public static java.lang.String extractTenant(java.lang.String prefixedName)
public java.lang.String addTenantPrefix(java.lang.String value)
public java.lang.String prefix()
public int prefixSizeInBytes()
public org.apache.kafka.common.TopicPartition removeTenantPrefix(org.apache.kafka.common.TopicPartition tp)
public static java.lang.String removePrefix(java.lang.String value)
public java.lang.String removeTenantPrefix(java.lang.String value)
public static boolean hasTenantPrefix(java.lang.String prefix, java.lang.String prefixedName)
public boolean hasTenantPrefix(java.lang.String value)
public java.lang.String removeAllTenantPrefixes(java.lang.String message)
public int sizeOfRemovedPrefixes(java.lang.String message)
public java.lang.String prefixedWildcard()