Package com.linkedin.venice.pubsub.api

Interface PubSubProduceResult

All Known Implementing Classes:
ApacheKafkaProduceResult, SimplePubSubProduceResultImpl
public interface PubSubProduceResult
An interface implemented by specific PubSubProducerAdapters to return the result of a produce action.

  • Method Summary

    Modifier and Type
    Method
    Description
    long
    getOffset()
    The offset of the record in the topic/partition.
    int
    getPartition()
    The partition the record was sent to
    int
    getSerializedSize()
    Sum of the size of the serialized, uncompressed key and value in bytes.
    String
    getTopic()
    The topic the record was appended to

  • Method Details

    • getOffset

      long getOffset()
      The offset of the record in the topic/partition.

    • getSerializedSize

      int getSerializedSize()
      Sum of the size of the serialized, uncompressed key and value in bytes.

    • getTopic

      String getTopic()
      The topic the record was appended to

    • getPartition

      int getPartition()
      The partition the record was sent to