We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 07a47be commit 541162cCopy full SHA for 541162c
1 file changed
tests/asyncio_test.py
@@ -93,8 +93,7 @@ async def test_batch_end_to_end(self):
93
msg_ids = await asyncio.gather(*tasks)
94
self.assertEqual(len(msg_ids), 5)
95
# pylint: disable=fixme
96
- # TODO: the result is wrong due to https://github.com/apache/pulsar-client-cpp/issues/531
97
- self.assertEqual(producer.last_sequence_id(), 8)
+ self.assertEqual(producer.last_sequence_id(), 4)
98
ledger_id = msg_ids[0].ledger_id()
99
entry_id = msg_ids[0].entry_id()
100
# These messages should be in the same entry
0 commit comments