public class MultiTenantApis
extends java.lang.Object
TransformableSchema
for Kafka APIs which apply the multi-tenant
transformations needed to enforce tenant isolation. In particular, topic names, consumer groups,
and producer transactional ids are prefixed with the tenant name on request deserialization.
On response serialization, this prefix is stripped off.Constructor and Description |
---|
MultiTenantApis() |
Modifier and Type | Method and Description |
---|---|
static boolean |
isApiAllowed(org.apache.kafka.common.protocol.ApiKeys api)
Check whether an API is supported.
|
static TransformableType<TenantContext> |
requestSchema(org.apache.kafka.common.protocol.ApiKeys api,
short version) |
static TransformableType<TenantContext> |
responseSchema(org.apache.kafka.common.protocol.ApiKeys api,
short version) |
public static boolean isApiAllowed(org.apache.kafka.common.protocol.ApiKeys api)
public static TransformableType<TenantContext> requestSchema(org.apache.kafka.common.protocol.ApiKeys api, short version)
public static TransformableType<TenantContext> responseSchema(org.apache.kafka.common.protocol.ApiKeys api, short version)