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