Задержка начала потребления сообщений

У меня очень простой потребитель Reactor Kafka.

Однако для того, чтобы сообщение обрабатывалось должным образом, необходимо предварительно выполнить пару @Postconstruct.

@Postconstruct инициализирует некоторые объекты в памяти, подготавливает данные и т. д.

Если сообщения начинают потребляться, но @Postconstruct не завершена, обработка сообщения обязательно завершится ошибкой.

Для завершения @Postconstruct требуется некоторое время, примерно 3 секунды. Что я пробовал: Поэтому в настоящее время в моем коде я бы просто обрабатывал сообщения, и в течение первых 3-х секунд вся обработка сообщений завершалась сбоем, и я бы помещал неудавшиеся сообщения в другую тему.

В какой-то момент, через 3 секунды, @Postconstruct завершается, сообщения обрабатываются нормально, доволен.

Тем не менее, я нашел это очень избыточным, у меня есть другая тема и другая работа, которая существует только здесь, чтобы повторно обработать сообщения, которые не удалось выполнить в течение этих 3 секунд.

Есть ли более простой способ сказать Reactor Kafka только начать потребление, только после завершения @Postconstruct (возможно, отправив какой-то сигнал в приложение), или, может быть, даже просто подождать 3 секунды?

До сих пор я пробовал это:

  public Flux<String> myConsumer() {
        return KafkaReceiver
                .create(receiverOptions)
                .receive()
                .delayUntil(a -> Mono.delay(Duration.ofSeconds(4)))
                .flatMap((oneMessage) ->
                        Mono.deferContextual(contextView -> {
                            var scope = ContextSnapshot.setAllThreadLocalsFrom(contextView);
                            try (scope) {
                                return consume(oneMessage);
                            }
                        }), 500)
                .name("greeting.call")      //1
                .tag("latency", "low")  //2
                .tap(Micrometer.observation(observationRegistry));

Однако он не делает того, что я ожидаю, он просто откладывает.