Class SequencedMessage

public abstract class SequencedMessage

A message with its sequencing information in the partition.

Inheritance

java.lang.Object > SequencedMessage

Constructors

SequencedMessage()

public SequencedMessage()

Methods

byteSize()

public abstract long byteSize()

The amount of quota bytes this message counts for.

Returns
TypeDescription
long

fromProto(SequencedMessage proto)

public static SequencedMessage fromProto(SequencedMessage proto)

Convert a SequencedMessage proto to a SequencedMessage.

Parameter
NameDescription
protoSequencedMessage
Returns
TypeDescription
SequencedMessage

message()

public abstract Message message()

The underlying user Message.

Returns
TypeDescription
Message

of(Message message, Timestamp publishTime, Offset offset, long byteSize)

public static SequencedMessage of(Message message, Timestamp publishTime, Offset offset, long byteSize)

Construct a SequencedMessage from its components.

Parameters
NameDescription
messageMessage
publishTimeTimestamp
offsetOffset
byteSizelong
Returns
TypeDescription
SequencedMessage

offset()

public abstract Offset offset()

The offset for this message.

Returns
TypeDescription
Offset

publishTime()

public abstract Timestamp publishTime()

The time when the message was published.

Returns
TypeDescription
Timestamp

toProto()

public SequencedMessage toProto()

Convert to a SequencedMessage proto.

Returns
TypeDescription
SequencedMessage