bph-sag commented on issue #424:
URL:
https://github.com/apache/pulsar-client-cpp/issues/424#issuecomment-2079446323
So, looking at the internal stats for the topic, it does appear that the
mark-delete position indicates that the full batch is indeed acknowledged for
our aarch32 runs.
### Unsuccessful run, with missed events
#### Log lines before termination of first consumer (last acknowledgement
and the message associated with that acknowledgement, aarch32)
(Ledger 17, entry 1, 190/309)
```log
2024-04-26 14:44:32.322 INFO [3944048800] -
<connectivity.pulsarTransport.my_dynamic_chain_instance> Got Message with batch
index: 190, of batch size: 309, ledger: 17, entry: 1, full message was: [...]
2024-04-26 14:44:32.324 INFO [3944048800] -
<connectivity.pulsarTransport.my_dynamic_chain_instance> SUCCESS ACK -
partition: -1, ledgerId: 17, entryId: 1, batchIndex: 190, topicName:
persistent://public/default/ConnPlugincor24546ea9837f45e49629df60696e54502e4
```
#### Mark delete position from
`persistent/:tenant/:namespace/:topic/internalStats?authoritative=false&metadata=false`
```json
"markDeletePosition": "17:1",
```
#### First message received on the 2nd consumer
(Ledger 17, entry 2, 1/309)
```
2024-04-26 14:45:03.577 INFO [3948247200] -
<connectivity.pulsarTransport.my_dynamic_chain_instance> Got Message with batch
index: 0, of batch size: 309, ledger: 17, entry: 2, full message was: [...]
```
### Successful run, no missing messages (x86_64)
#### Last messages prior to shutdown
(Ledger 36, entry 2, 198/309)
```log
2024-04-25 14:18:49.657 INFO [3946145952] -
<connectivity.pulsarTransport.my_dynamic_chain_instance> SUCCESS ACK -
partition: -1, ledgerId: 36, entryId: 2, batchIndex: 198, topicName:
persistent://public/default/ConnPlugincor245ae0980739d4344e98f3f3b29f0f07d8b
2024-04-25 14:18:49.657 INFO [3946145952] -
<connectivity.pulsarTransport.my_dynamic_chain_instance> Got Message with batch
index: 198, of batch size: 309, ledger: 36, entry: 2, full message was: [...]
```
#### Mark delete position from
`persistent/:tenant/:namespace/:topic/internalStats?authoritative=false&metadata=false`
```json
"markDeletePosition": "36:1",
```
#### First message received on 2nd consumer
(Ledger 36, entry 2, 1/309)
```
2024-04-25 14:19:11.523 INFO [3948247200] -
<connectivity.pulsarTransport.my_dynamic_chain_instance> Got Message with batch
index: 0, of batch size: 309, ledger: 36, entry: 2, full message was: [...]
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
