Interface PubSubMessage<K,​V,​OFFSET>

    • Method Detail

      • getKey

        K getKey()
        Returns:
        the key part of this message
      • getValue

        V getValue()
        Returns:
        the value part of this message
      • getTopicPartition

        PubSubTopicPartition getTopicPartition()
        Returns:
        the topic-partition this message belongs to
      • getOffset

        OFFSET getOffset()
        Returns:
        the offset of this message in the underlying topic-partition
      • getPubSubMessageTime

        long getPubSubMessageTime()
        Returns:
        the timestamp at which the message was persisted in the pub sub system
      • getPayloadSize

        int getPayloadSize()
        Returns:
        the size in bytes of the key + value.
      • getTopicName

        default java.lang.String getTopicName()
      • getPartition

        default int getPartition()
      • isEndOfBootstrap

        boolean isEndOfBootstrap()
        Returns:
        whether this message marks the end of bootstrap.