Skip to content

Commit e36d458

Browse files
committed
Fix Test
1 parent 8fe9406 commit e36d458

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -928,6 +928,14 @@ public KafkaListenerErrorHandler voidSendToErrorHandler() {
928928
};
929929
}
930930

931+
@Bean
932+
public KafkaListenerErrorHandler consumeMultiMethodException(MultiListenerBean listener) {
933+
return (m, e) -> {
934+
listener.errorLatch.countDown();
935+
return null;
936+
};
937+
}
938+
931939
}
932940

933941
static class Listener implements ConsumerSeekAware {
@@ -1275,14 +1283,6 @@ public CountDownLatch getLatch2() {
12751283
return latch2;
12761284
}
12771285

1278-
@Bean
1279-
public KafkaListenerErrorHandler consumeMultiMethodException(MultiListenerBean listener) {
1280-
return (m, e) -> {
1281-
listener.errorLatch.countDown();
1282-
return null;
1283-
};
1284-
}
1285-
12861286
}
12871287

12881288
@KafkaListener(id = "multi", topics = "annotated8", errorHandler = "consumeMultiMethodException")

0 commit comments

Comments
 (0)