This commit is contained in:
Gary Russell
2018-12-14 13:37:38 -05:00
parent 8fe9406c2f
commit e36d458c35

View File

@@ -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")