使用replyingkafkatemplate手动确认(提交)kafka消息

ubby3x7f  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(747)

我正在使用replyingkafkatemplate.sendandreceive()发送和接收一条与相关id相关的消息。用例中有许多主题,我需要手动确认(提交)消耗的消息。到目前为止,这是通过使用:

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

但我不知道´我不知道如何手动确认最后一条消息(sendandreceive()使用的消息)。
有什么提示吗?
谢谢
费尔南多

368yc8dk

368yc8dk1#

目前不支持手动提交回复消息的偏移量。
如果您可以解释一个有效的用例来说明为什么可能需要这样做,那么可以在github上打开一个新的特性请求问题。

相关问题