import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
+import org.springframework.kafka.listener.CommonContainerStoppingErrorHandler;
import java.util.function.Consumer;
// Handle record
};
}
+
+ @Bean
+ public ApplicationErrorHandler errorHandler()
+ {
+ return new ApplicationErrorHandler();
+ }
}