public class ClusterLinkApis
extends java.lang.Object
TransformableSchema
for Cluster Link requests to the source cluster which
apply multi-tenant transformations and in future may also be used to support topic renaming.
Only topics and ACLs are transformed.Constructor and Description |
---|
ClusterLinkApis() |
Modifier and Type | Method and Description |
---|---|
static boolean |
isApiAllowed(org.apache.kafka.common.protocol.ApiKeys api) |
static TransformableType<LinkContext> |
requestSchema(org.apache.kafka.common.protocol.ApiKeys api,
short version) |
static TransformableType<LinkContext> |
responseSchema(org.apache.kafka.common.protocol.ApiKeys api,
short version) |
public static boolean isApiAllowed(org.apache.kafka.common.protocol.ApiKeys api)
public static TransformableType<LinkContext> requestSchema(org.apache.kafka.common.protocol.ApiKeys api, short version)
public static TransformableType<LinkContext> responseSchema(org.apache.kafka.common.protocol.ApiKeys api, short version)