public class LinkContext extends Object implements org.apache.kafka.common.protocol.MessageContext
Constructor and Description |
---|
LinkContext(String localTenantPrefix,
String clusterLinkPrefix,
String linkName,
Boolean prefixConsumerGroupWithClusterPrefix) |
Modifier and Type | Method and Description |
---|---|
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) |
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