In Pulsar, a message ID tuple like (754763,11,0,-1) represents (ledgerId, entryId, partitionIndex, batchIndex). Specifically:
- 754763: ledgerId
- 11: entryId
- 0: partitionIndex
- -1: batchIndex (where -1 means not a batched message)
This format is used across Pulsar clients and APIs to uniquely identify a message's position in the log. For more, see
pulsar-client-python MessageId docs and
Java MessageIdImpl.
Would you like more detail on how these fields are used?
Sources:
-
pulsar-client-python MessageId
-
Java MessageIdImpl.java 👍 1 button 👎 0 button 💡
Hint: Mention
@RunLLM in the thread for followups.