io.confluent.kafka.link

Class LinkContext

java.lang.Object

io.confluent.kafka.link.LinkContext

All Implemented Interfaces:

org.apache.kafka.common.protocol.MessageContext

public class LinkContext
extends Object
implements org.apache.kafka.common.protocol.MessageContext

Field Summary

Fields inherited from interface org.apache.kafka.common.protocol.MessageContext

IDENTITY

Constructor Summary

Constructors

Constructor and Description
LinkContext(String localTenantPrefix, String clusterLinkPrefix, String linkName, Boolean prefixConsumerGroupWithClusterPrefix)

Method Summary

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)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LinkContext

public LinkContext(String localTenantPrefix,
                   String clusterLinkPrefix,
                   String linkName,
                   Boolean prefixConsumerGroupWithClusterPrefix)

Method Detail

linkName

public String linkName()

write

public String write(org.apache.kafka.common.protocol.EntityType entityType,
                    String value)

Specified by:

write in interface org.apache.kafka.common.protocol.MessageContext

write

public org.apache.kafka.common.protocol.Message write(org.apache.kafka.common.protocol.EntityType entityType,
                                                      org.apache.kafka.common.protocol.Message value)

Specified by:

write in interface org.apache.kafka.common.protocol.MessageContext

read

public String read(org.apache.kafka.common.protocol.EntityType entityType,
                   String value)

Specified by:

read in interface org.apache.kafka.common.protocol.MessageContext

read

public org.apache.kafka.common.protocol.Message read(org.apache.kafka.common.protocol.EntityType entityType,
                                                     org.apache.kafka.common.protocol.Message value)

Specified by:

read in interface org.apache.kafka.common.protocol.MessageContext