- public EndlessConsumer<String, Message> endlessConsumer(
- Consumer<String, Message> kafkaConsumer,
- ExecutorService executor,
- ApplicationRebalanceListener rebalanceListener,
+ public ApplicationErrorHandler applicationErrorHandler()
+ {
+ return new ApplicationErrorHandler();
+ }
+
+ @Bean
+ public EndlessConsumer endlessConsumer(