nicoloboschi opened a new pull request, #17161:
URL: https://github.com/apache/pulsar/pull/17161
### Motivation
```
java.lang.AssertionError: expected [600] but found [265]
at org.testng.Assert.fail(Assert.java:99)
at org.testng.Assert.failNotEquals(Assert.java:1037)
at org.testng.Assert.assertEqualsImpl(Assert.java:140)
at org.testng.Assert.assertEquals(Assert.java:122)
at org.testng.Assert.assertEquals(Assert.java:907)
at org.testng.Assert.assertEquals(Assert.java:917)
at
org.apache.pulsar.client.api.DispatcherBlockConsumerTest.testBrokerDispatchBlockAndSubAckBackRequiredMsgs(DispatcherBlockConsumerTest.java:1036)
```
### Modifications
In the scope of this test is important to not group acks because the ack for
messages may happens after receiving a new message from the topic. If the acks
are sent in batch it may happen that the dispatcher is still blocked until it
receives the batched acks and the Consumer#receive will return null and the
test will fail.
- Set acknowledgmentGroupTime to 0 for the consumer
- Moved the test to the `broker` suite (it was `flaky`)
- [x] `doc-not-needed`
--
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]
