public static class PubSubHelper.MutablePubSubMessage
extends java.lang.Object

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`KafkaKey`	`getKey()`
`java.lang.Long`	`getOffset()`
`long`	`getTimestampAfterProduce()`
`long`	`getTimestampBeforeProduce()`
`PubSubTopicPartition`	`getTopicPartition()`
`KafkaMessageEnvelope`	`getValue()`
`PubSubHelper.MutablePubSubMessage`	`setKey(KafkaKey key)`
`PubSubHelper.MutablePubSubMessage`	`setOffset(long offset)`
`PubSubHelper.MutablePubSubMessage`	`setTimestampAfterProduce(long timestampAfterProduce)`
`PubSubHelper.MutablePubSubMessage`	`setTimestampBeforeProduce(long timestampBeforeProduce)`
`PubSubHelper.MutablePubSubMessage`	`setTopicPartition(PubSubTopicPartition topicPartition)`
`PubSubHelper.MutablePubSubMessage`	`setValue(KafkaMessageEnvelope value)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

public KafkaMessageEnvelope getValue()

public PubSubTopicPartition getTopicPartition()

public PubSubHelper.MutablePubSubMessage setKey(KafkaKey key)

public PubSubHelper.MutablePubSubMessage setValue(KafkaMessageEnvelope value)

public PubSubHelper.MutablePubSubMessage setTopicPartition(PubSubTopicPartition topicPartition)

public PubSubHelper.MutablePubSubMessage setOffset(long offset)

public PubSubHelper.MutablePubSubMessage setTimestampBeforeProduce(long timestampBeforeProduce)

public PubSubHelper.MutablePubSubMessage setTimestampAfterProduce(long timestampAfterProduce)

public long getTimestampBeforeProduce()

public long getTimestampAfterProduce()

Class PubSubHelper.MutablePubSubMessage