merlimat opened a new pull request, #25499: URL: https://github.com/apache/pulsar/pull/25499
## Summary - **InterceptorsTest.testReaderInterceptor**: `interceptor3` is on a listener-based reader (`reader2`), so messages are delivered asynchronously. The assertion `assertTrue(interceptor3.encounterException.get())` was checked immediately after `produceAndConsume` returned, but the listener may not have processed enough messages yet. Wrapped in `Awaitility.await()`. - **ProduceWithMessageIdTest.sendWithCallBack**: The `uncompressedSize` includes the batch buffer allocation whose actual capacity depends on the Netty allocator (alignment, pooling) and may differ from `INITIAL_BATCH_BUFFER_SIZE`. Changed from exact equality to `>=` check. ## Test plan - [ ] Verify `InterceptorsTest.testReaderInterceptor` passes for both partitioned and non-partitioned topics - [ ] Verify `ProduceWithMessageIdTest.sendWithCallBack` passes -- 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]
