Асинхронный метод, запускаемый потребителем Kafka, получает исключение RejectedExecutionException: ExecutorService в сос ⇐ JAVA

[Anonymous]

Потребитель 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