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 fa8a81a0bf..0bbfdf1342 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 @@ -32,8 +32,10 @@ import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.common.serialization.StringSerializer; import org.junit.jupiter.api.Test; +import org.junit.jupiter.api.condition.DisabledIfEnvironmentVariable; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.kafka.annotation.EnableKafka; @@ -65,6 +67,8 @@ /** * @author Sanghyeok An + * @author Artem Bilan + * * @since 3.3.0 */ @@ -437,9 +441,12 @@ void oneLongSuccessMsgBetween100ShortFailMsg( } @Test + @DisabledIfEnvironmentVariable(named = "GITHUB_ACTION", matches = ".*?", + disabledReason = "Fails sporadically. Perhaps uses too much Apache Kafka resources") void halfSuccessMsgAndHalfFailedMsgWithRandomSleepTime( @Autowired TestTopicListener6 topicListener6, - @Autowired MyCustomDltProcessor myCustomDltProcessor6) { + @Autowired @Qualifier("myCustomDltProcessor6") MyCustomDltProcessor myCustomDltProcessor6) { + // Given DestinationTopic destinationTopic = topicContainer.getNextDestinationTopicFor("6-TopicId", TEST_TOPIC6);