- ConcurrentKafkaListenerContainerFactory<String, Long> factory =
- new ConcurrentKafkaListenerContainerFactory<>();
-
- factory.setConsumerFactory(consumerFactory);
- factory.setCommonErrorHandler(errorHandler);
- factory.setBatchListener(true);
-
- return factory;
- }
-
- @Bean
- public CommonContainerStoppingErrorHandler errorHandler()
- {
- return new CommonContainerStoppingErrorHandler();