diff --git a/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/AsyncCompletableFutureRetryTopicScenarioTests.java b/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/AsyncCompletableFutureRetryTopicScenarioTests.java index 20200084cb..e9948dae17 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/AsyncCompletableFutureRetryTopicScenarioTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/AsyncCompletableFutureRetryTopicScenarioTests.java @@ -439,7 +439,7 @@ void longSuccessMsgTwiceThenShortFailMsgTwice( } @Test - void oneLongSuccessMsgBetween100ShortFailMsg( + void oneLongSuccessMsgBetween49ShortFailMsg( @Autowired TestTopicListener5 topicListener5, @Autowired MyCustomDltProcessor myCustomDltProcessor5) { // Scenario. diff --git a/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/AsyncMonoRetryTopicScenarioTests.java b/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/AsyncMonoRetryTopicScenarioTests.java index 57ad1904c8..a1ca877b89 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/AsyncMonoRetryTopicScenarioTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/retrytopic/AsyncMonoRetryTopicScenarioTests.java @@ -437,7 +437,7 @@ void longSuccessMsgTwiceThenShortFailMsgTwice( } @Test - void oneLongSuccessMsgBetween100ShortFailMsg( + void oneLongSuccessMsgBetween49ShortFailMsg( @Autowired TestTopicListener5 topicListener5, @Autowired MyCustomDltProcessor myCustomDltProcessor5) { // Scenario.