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
    Description
    LinkContext(String localTenantPrefix, String clusterLinkPrefix, String linkName, Boolean prefixConsumerGroupWithClusterPrefix)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    linkName()
     
    String
    read(org.apache.kafka.common.protocol.EntityType entityType, String value)
     
    org.apache.kafka.common.protocol.Message
    read(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)
     
    org.apache.kafka.common.protocol.Message
    write(org.apache.kafka.common.protocol.EntityType entityType, org.apache.kafka.common.protocol.Message value)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • LinkContext

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

  • Method Details

    • 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