Потребитель Kafka Spring Boot получает RejectedExecutionException: ExecutorService в состоянии завершения работы при запуске завершения работы.
Я пытался использовать Spring.kafka.listener.immediate-stop: true< /code> конфигурация для немедленной остановки потребителя, но по-прежнему возникает та же ошибка.
Есть ли способ позволить асинхронному методу принимать задачи до тех пор, пока потребитель Kafka не обработает все сообщения, опросенные во время завершения работы?Вот пример кода:
@Service
public class AsyncService {
@Async
void testAsync() {
System.out.println("Async task is working");
}
}
@Slf4j
@Component
@AllArgsConstructor
public class KafkaConsumer {
protected final AsyncService asyncService;
@Bean
public Consumer flightEventConsumer() {
return msg -> {
log.info(msg.toString());
};
}
@Bean
public Consumer dailyConsumer() {
return msg -> {
log.info(">>>
Подробнее здесь: https://stackoverflow.com/questions/787 ... ion-execut
