Как реализовать параллельную обработку внутри одного консюмера с ожиданием завершения? (Virtual Threads)