}
@Bean
- public ApplicationErrorHandler applicationErrorHandler()
- {
- return new ApplicationErrorHandler();
- }
-
- @Bean
- public EndlessConsumer<String, Message> endlessConsumer(
+ public EndlessConsumer endlessConsumer(
RecordHandler recordHandler,
- ApplicationErrorHandler errorHandler,
KafkaProperties kafkaProperties,
KafkaListenerEndpointRegistry endpointRegistry)
{
return
- new EndlessConsumer<>(
+ new EndlessConsumer(
kafkaProperties.getClientId(),
endpointRegistry,
- errorHandler,
recordHandler);
}
}