diff --git a/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java b/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java index 5cf5c7a3..4723366c 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java @@ -928,6 +928,14 @@ public class EnableKafkaIntegrationTests { }; } + @Bean + public KafkaListenerErrorHandler consumeMultiMethodException(MultiListenerBean listener) { + return (m, e) -> { + listener.errorLatch.countDown(); + return null; + }; + } + } static class Listener implements ConsumerSeekAware { @@ -1275,14 +1283,6 @@ public class EnableKafkaIntegrationTests { return latch2; } - @Bean - public KafkaListenerErrorHandler consumeMultiMethodException(MultiListenerBean listener) { - return (m, e) -> { - listener.errorLatch.countDown(); - return null; - }; - } - } @KafkaListener(id = "multi", topics = "annotated8", errorHandler = "consumeMultiMethodException")