IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

README update about customized Pular driver exception

Browse Source
This commit is contained in:
Yabin Meng 2021-09-29 11:37:07 -05:00
parent 949790b797
commit d781e1ac22
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
driver-pulsar/src/main/resources/pulsar.md
View File

@ -727,11 +727,14 @@ which is also monotonically increasing by 1.
When receiving the messages, if the message sequence number stored in the message
property is not monotonically increasing or if there is a gap larger than 1, then
it must be one of the following errors:
* if the current message sequence ID is less than the previous message sequence ID, then
it is message out-of-order error
* if the current message sequence ID is more than 1 bigger than the previous message sequence
ID, then it is message loss error
* if message dedup is enabled and the current message sequence ID is equal to the previous message sequence ID, then it is message duplication error
* If the current message sequence ID is less than the previous message sequence ID,
then it is message out-of-order error. Exception **PulsarMsgOutOfOrderException**
will be thrown out.
* if the current message sequence ID is more than 1 bigger than the previous message
sequence ID, then it is message loss error. Exception **PulsarMsgLossException**
will be thrown out.
* if message dedup is enabled and the current message sequence ID is equal to the
previous message sequence ID, then it is message duplication error. Exception **PulsarMsgDuplicateException** will be thrown out.
In either case, a runtime error will be thrown out with corresponding error messages.