Fix flaky tests in async retry by using a latch instead of sleep.

[chickenchickenlove]

Motivation

In the previous version, all test cases depended on sleep.
However, it made all test cases flaky.
(Please refer to this comment #3523 (comment))

Modification

• Removed sleep.
• Used latch instead.

Result

• Fixes flaky test cases in AsyncCompletableFutureRetryTopicScenarioTests, AsyncMonoRetryTopicScenarioTests.

To Reviewer,

I removed a test case. that involved a random situation.
However, it is very hard to handle a random situation with a latch.
Therefore, I decided to remove it and create a new test with a more complex scenario.

[artembilan]

Thank you for looking into this @chickenchickenlove !

If you think it is OK now, then consider to remove that @DisabledIfEnvironmentVariable in the AsyncCompletableFutureRetryTopicScenarioTests.

[artembilan]

You have missed to remove an import org.junit.jupiter.api.condition.DisabledIfEnvironmentVariable;.
It is still going to fail for Checkstyle.
That's why it is better to run ./gradlew check locally before pushing changes to the PR.

[chickenchickenlove]

@artembilan Thanks for your quick review!
I think it's okay. Therefore, I removed @DisabledIfEnvironmentVariable.
I believe the test execution time has been reduced by approximately 40 to 50 seconds.

• Decrease retry count from 5 to 3.
• Decrease msg count from 100 to 50.
• Removed sleep.
• Used latch.

When you have time, please take a look 🙇‍♂️

[artembilan]

Looks like it is not OK yet:

AsyncCompletableFutureRetryTopicScenarioTests > moreComplexAsyncScenarioTest(TestTopicListener6, MyCustomDltProcessor) FAILED
    org.opentest4j.AssertionFailedError: 
    Expecting actual:
      ["fail0",
        "success1",
        "success2",
        "fail3",
        "success4",
        "fail0",
        "fail3",
        "fail0",
        "fail3"]
    to contain exactly (and in same order):
      ["fail0",
        "success1",
        "success2",
        "fail3",
        "success4",
        "fail3",
        "fail3",
        "fail0",
        "fail0"]
    but there were differences at these indexes:
      - element at index 5: expected "fail3" but was "fail0"
      - element at index 8: expected "fail0" but was "fail3"
        at java.base@17.0.12/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
        at java.base@17.0.12/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:77)
        at java.base@17.0.12/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
        at java.base@17.0.12/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:500)
        at app//org.springframework.kafka.retrytopic.AsyncCompletableFutureRetryTopicScenarioTests.moreComplexAsyncScenarioTest(AsyncCompletableFutureRetryTopicScenarioTests.java:572)

[chickenchickenlove]

Thanks for your review, and I apologize for the inconvenience 🙇‍♂️.
I decided to use containsExactlyInAnyOther() instead of containsExactly().
Because, I think an issue which i cannot control seems occurs when kafkaTemplate.send(...)