Pause consuming at the application startup

[cj19]

I am using Quarkus and reactive messaging (KafkaClientService) and trying to pause consuming of messages in one channel.
Got the proper application config:

mp.messaging.incoming.inbound-channel-test.pause-if-no-requests=false

Also tried using application lifecycle events to stop consuming but it is not guaranteed that the consumer is assigned to the partition at that time. Used @PostConstruct and StartupEvent already like the following:

void onStartup(@Observes StartupEvent startupEvent) {
        Log.infof("Starting Kafka consumer controller, pausing consumers");
        pauseConsumerAtStartup();
 }
 
 private void pauseConsumerAtStartup() {
        kafkaClientService.getConsumer(consumer)
                .runOnPollingThread(kafkaConsumer -> {
                    kafkaConsumer.pause(kafkaConsumer.assignment());
                })
                .subscribeAsCompletionStage()
        
}

The other way was that i added startup annotation to the class and classed the pauseConsumer at the PostConstruct annotated method. Is there a clean way to do this?