pulsar.MessageId

class documentation

class MessageId: (source)

Constructor: MessageId(partition, ledger_id, entry_id, batch_index)

View In Hierarchy

Represents a message id.

Static Method deserialize Deserialize a message id object from a previously serialized bytes sequence.
Method __init__ Undocumented
Method __str__ Returns the string representation of the message id.
Method batch_index Undocumented
Method entry_id Undocumented
Method ledger_id Undocumented
Method partition Undocumented
Method serialize Returns a bytes representation of the message id. This byte sequence can be stored and later deserialized.
Instance Variable earliest Represents the earliest message stored in a topic
Instance Variable latest Represents the latest message published on a topic
Instance Variable _msg_id Undocumented
@staticmethod
def deserialize(message_id_bytes): (source)

Deserialize a message id object from a previously serialized bytes sequence.

def __init__(self, partition=-1, ledger_id=-1, entry_id=-1, batch_index=-1): (source)

Undocumented

def __str__(self) -> str: (source)

Returns the string representation of the message id.

def batch_index(self): (source)

Undocumented

def entry_id(self): (source)

Undocumented

def ledger_id(self): (source)

Undocumented

def partition(self): (source)

Undocumented

def serialize(self): (source)

Returns a bytes representation of the message id. This byte sequence can be stored and later deserialized.

earliest = (source)

Represents the earliest message stored in a topic

latest = (source)

Represents the latest message published on a topic

_msg_id = (source)

Undocumented