Describe the bug
The test for Should read the unacknowledged message again before the rest of the flow, in batch, in shared subscription, checks that there are 4 messages received while in the pulsar documentation it states that if you negatively acknowledge a message in a batch it resends the whole batch.
Reproduce
Please provide reproduce, For example:
Run the consumer tests
The test sometimes fails and says it has more messages than expected in the expected queue
Expected behavior
The test should pass every time
Observed behavior
A clear and concise description of what did happen. Please include any relevant logs.
Describe the bug The test for Should read the unacknowledged message again before the rest of the flow, in batch, in shared subscription, checks that there are 4 messages received while in the pulsar documentation it states that if you negatively acknowledge a message in a batch it resends the whole batch.
Reproduce Please provide reproduce, For example: