public class LinkContext extends Object implements org.apache.kafka.common.protocol.MessageContext
Constructor and Description |
---|
LinkContext(String localTenantPrefix,
String clusterLinkPrefix,
String linkName) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
isTransformRequired(org.apache.kafka.common.config.ConfigResource.Type resourceType) |
protected boolean |
isTransformRequired(org.apache.kafka.common.resource.ResourceType resourceType) |
String |
linkName() |
org.apache.kafka.common.protocol.Message |
read(org.apache.kafka.common.protocol.EntityType entityType,
org.apache.kafka.common.protocol.Message value) |
String |
read(org.apache.kafka.common.protocol.EntityType entityType,
String value) |
protected void |
transformDestToSource(org.apache.kafka.common.message.DescribeConfigsRequestData.DescribeConfigsResource resource) |
protected void |
transformSourceToDest(org.apache.kafka.common.message.DescribeConfigsResponseData.DescribeConfigsResult resource) |
org.apache.kafka.common.protocol.Message |
write(org.apache.kafka.common.protocol.EntityType entityType,
org.apache.kafka.common.protocol.Message value) |
String |
write(org.apache.kafka.common.protocol.EntityType entityType,
String value) |
public String linkName()
public String write(org.apache.kafka.common.protocol.EntityType entityType, String value)
write
in interface org.apache.kafka.common.protocol.MessageContext
public org.apache.kafka.common.protocol.Message write(org.apache.kafka.common.protocol.EntityType entityType, org.apache.kafka.common.protocol.Message value)
write
in interface org.apache.kafka.common.protocol.MessageContext
public String read(org.apache.kafka.common.protocol.EntityType entityType, String value)
read
in interface org.apache.kafka.common.protocol.MessageContext
public org.apache.kafka.common.protocol.Message read(org.apache.kafka.common.protocol.EntityType entityType, org.apache.kafka.common.protocol.Message value)
read
in interface org.apache.kafka.common.protocol.MessageContext
protected void transformDestToSource(org.apache.kafka.common.message.DescribeConfigsRequestData.DescribeConfigsResource resource)
protected void transformSourceToDest(org.apache.kafka.common.message.DescribeConfigsResponseData.DescribeConfigsResult resource)
protected boolean isTransformRequired(org.apache.kafka.common.config.ConfigResource.Type resourceType)
protected boolean isTransformRequired(org.apache.kafka.common.resource.ResourceType resourceType)