public abstract class SequencedMessage
A message with its sequencing information in the partition.
Inherited Members
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.
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 |