Class SequencedMessage (1.13.3)

Version 1.13.3

• 1.13.6 (latest)
• 1.13.5
• 1.12.22
• 1.11.2
• 1.10.0
• 1.9.4
• 1.8.0
• 1.7.1
• 1.6.3
• 1.5.5
• 1.4.12

public abstract class SequencedMessage

A message with its sequencing information in the partition.

Inheritance

java.lang.Object > SequencedMessage

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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