我正在使用replyingkafkatemplate.sendandreceive()发送和接收一条与相关id相关的消息。用例中有许多主题,我需要手动确认(提交)消耗的消息。到目前为止,这是通过使用:
@KafkaListener(topics = "${kafka.topic.request-topic}")
@SendTo("int1")
public Tx30 listen(@Payload Tx30 request, Acknowledgment ack) throws InterruptedException {
...
ack.acknowledge();
但我不知道´我不知道如何手动确认最后一条消息(sendandreceive()使用的消息)。
有什么提示吗?
谢谢
费尔南多
1条答案
按热度按时间368yc8dk1#
目前不支持手动提交回复消息的偏移量。
如果您可以解释一个有效的用例来说明为什么可能需要这样做,那么可以在github上打开一个新的特性请求问题。