Class SequencedMessage (1.14.3)

public abstract class SequencedMessage

A message with its sequencing information in the partition.

Inheritance

java.lang.Object > SequencedMessage

Static Methods

fromProto(SequencedMessage proto)

public static SequencedMessage fromProto(SequencedMessage proto)

Convert a SequencedMessage proto to a SequencedMessage.

Parameter
Name Description
proto SequencedMessage
Returns
Type Description
SequencedMessage

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
Name Description
message Message
publishTime Timestamp
offset Offset
byteSize long
Returns
Type Description
SequencedMessage

Constructors

SequencedMessage()

public SequencedMessage()

Methods

byteSize()

public abstract long byteSize()

The amount of quota bytes this message counts for.

Returns
Type Description
long

message()

public abstract Message message()

The underlying user Message.

Returns
Type Description
Message

offset()

public abstract Offset offset()

The offset for this message.

Returns
Type Description
Offset

publishTime()

public abstract Timestamp publishTime()

The time when the message was published.

Returns
Type Description
Timestamp

toProto()

public SequencedMessage toProto()

Convert to a SequencedMessage proto.

Returns
Type Description
SequencedMessage