Приостановить и возобновить очередь сообщений микропрофиля Quarkus ⇐ JAVA

[Anonymous]

Меня интересует возможность приостановить использование очереди Kafka, когда возникнут проблемы с подключением клиента.
Я хочу использовать Retry и CircuitBreaker для клиента Rest (который вызывается после потребление сообщений). Поэтому это сообщение будет повторяться в цикле, на это время я хочу приостановить получение других сообщений из этой темы.
Возможно ли это в платформе Quarkus? Вот как сейчас выглядят потребители:

Код: Выделить всё

@Slf4j
@ApplicationScoped
public class MyKafkaConsumer {

@Inject
MyService myService;

@Incoming(KAFKA_CHANNEL)
@ActivateRequestContext
public CompletionStage receive(Message message) {
if (!isItExpectedMessage(message) {
message.ack();
}
myService.process(message);
message.ack();
}

Я не могу найти решения, позволяющего приостановить потребление и восстановить его во время обработки. Знаете ли вы какой-нибудь способ или обходной путь в этом случае?
Заранее спасибо!

Подробнее здесь: https://stackoverflow.com/questions/788 ... ging-queue