pdolif commented on issue #23825: URL: https://github.com/apache/pulsar/issues/23825#issuecomment-2692783674
```java assertEquals(consumer1.numMessagesInQueue(), batchMessages, batchMessages); ``` The assertion is problematic because it is fulfilled if the number of messages in the queue is 0. This makes the test pass with 0 messages in the queue before any messages are dispatched. When adding a delay before the assertion to wait for some messages to be dispatched, for example, 100ms, then the test constantly fails and 100 messages are in the queue (10 entries with one message batch of 10 messages each). -- 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]
