PubSubMessage (venice API)

All Superinterfaces:

Measurable

All Known Implementing Classes:

ImmutableChangeCapturePubSubMessage, ImmutablePubSubMessage, PubSubHelper.MutablePubSubMessage
```
public interface PubSubMessage<K,V,OFFSET>
extends Measurable
```

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	Description
`K`	`getKey()`
`OFFSET`	`getOffset()`
`default int`	`getPartition()`
`int`	`getPayloadSize()`
`default PubSubMessageHeaders`	`getPubSubMessageHeaders()`
`long`	`getPubSubMessageTime()`
`default PubSubTopic`	`getTopic()`
`default java.lang.String`	`getTopicName()`
`PubSubTopicPartition`	`getTopicPartition()`
`V`	`getValue()`
`boolean`	`isEndOfBootstrap()`

Methods inherited from interface com.linkedin.venice.memory.Measurable
getHeapSize

- 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()
```
  - getTopic
```
default PubSubTopic getTopic()
```
  - getPartition
```
default int getPartition()
```
  - isEndOfBootstrap
```
boolean isEndOfBootstrap()
```
    Returns:
    
    whether this message marks the end of bootstrap.
  - getPubSubMessageHeaders
```
default PubSubMessageHeaders getPubSubMessageHeaders()
```