Как получить подтверждение от потребителя брокеру в кафке

Question

У меня есть потребитель, который получает сообщение от брокера, я хочу выполнить некоторую задачу, когда потребитель получает сообщение, и когда конкретная задача заканчивается, потребитель получает другое сообщение.

 public class Consumer {
    private final Logger logger = LoggerFactory.getLogger(Consumer.class);
    @KafkaListener(topics = "gst", groupId = "group-1")
    public void consumeGst(String message){
            logger.info(String.format("$$ -> Consumed GST Message -> %s",message));

    }

    @KafkaListener(topics = "pf", groupId = "group-2")
    public void consumePf(String pfmessage) {
        logger.info(String.format("$$ -> ===============> Consumed Pf Message -> %s", pfmessage));
    }
}