Package com.linkedin.venice.controller.kafka.consumer

Class AdminMetadata

java.lang.Object
com.linkedin.venice.controller.kafka.consumer.AdminMetadata
public class AdminMetadata extends Object
Class representing admin topic metadata with strongly typed fields

  • Constructor Details

    • AdminMetadata

      public AdminMetadata()

    • AdminMetadata

      public AdminMetadata(Map<String,Object> metadataMap)

  • Method Details

    • toMap

      public Map<String,Object> toMap()

    • toLegacyMap

      public Map<String,Long> toLegacyMap()
      Convert AdminMetadata to legacy Map<String, Long> format for V1 compatibility This only includes the Long fields and excludes Position objects
      Returns:
      Map<String, Long> containing only the Long fields

    • fromLegacyMap

      public static AdminMetadata fromLegacyMap(Map<String,Long> legacyMap)
      Factory method to create AdminMetadata from legacy Map<String, Long> format

    • getExecutionId

      public Long getExecutionId()

    • setExecutionId

      public void setExecutionId(Long executionId)

    • getOffset

      public Long getOffset()

    • setOffset

      public void setOffset(Long offset)

    • getUpstreamOffset

      public Long getUpstreamOffset()

    • setUpstreamOffset

      public void setUpstreamOffset(Long upstreamOffset)

    • getAdminOperationProtocolVersion

      public Long getAdminOperationProtocolVersion()

    • setAdminOperationProtocolVersion

      public void setAdminOperationProtocolVersion(Long adminOperationProtocolVersion)

    • getPosition

      public PubSubPosition getPosition()

    • getUpstreamPosition

      public PubSubPosition getUpstreamPosition()

    • setPubSubPosition

      public void setPubSubPosition(PubSubPosition pubSubPosition)

    • setUpstreamPubSubPosition

      public void setUpstreamPubSubPosition(PubSubPosition upstreamPubPosition)

    • toString

      public String toString()
      Overrides:
      toString in class Object