Interface | Description |
---|---|
MessageEnvelope<K,M> |
An entry in the input/output
MessageStream s. |
Offset |
A generic interface extending
Comparable to be used as Offset in a stream |
Class | Description |
---|---|
IncomingSystemMessageEnvelope |
A
MessageEnvelope that provides additional information about its input SystemStreamPartition
and its Offset within the SystemStreamPartition . |
LongOffset |
An implementation of
Offset , w/ long value as the offset |