+
+ @Bean
+ public KafkaListenerContainerFactory<?> batchFactory(ConsumerFactory<String, Long> consumerFactory)
+ {
+ ConcurrentKafkaListenerContainerFactory<String, Long> factory =
+ new ConcurrentKafkaListenerContainerFactory<>();
+
+ factory.setConsumerFactory(consumerFactory);
+ factory.setBatchListener(true);
+
+ return factory;
+ }
+
+ @Bean
+ public CommonContainerStoppingErrorHandler errorHandler()
+ {
+ return new CommonContainerStoppingErrorHandler();
+ }