使用ReplyingKafkaTemboard手动确认（提交）kafka消息

Question

我正在使用ReplyingKafkaTemplate.sendAndReception（）发送和接收由相关ID关联的消息。用例有许多主题正在进行中，我需要手动acknoledge（提交）消耗的消息偏移量。到目前为止还不错，这是使用：

    @KafkaListener(topics = "${kafka.topic.request-topic}")
    @SendTo("int1")
    public Tx30 listen(@Payload Tx30 request, Acknowledgment ack) throws InterruptedException {
        ...
        ack.acknowledge();

但我不知道如何手动确认最后一条消息（sendAndReceive（）使用的消息）。

有什么提示吗？

谢谢

费尔南多

Answer 1

目前不支持手动提交回复消息的偏移量。

如果您可以解释为什么需要一个有效的用例，请随时在GitHub上打开一个新功能请求问题。