Go语言 如何列出nats jetstream的消息并知道它们是否被确认?

hfyxw5xn  于 2022-12-20  发布在  Go
关注(0)|答案(1)|浏览(258)

我需要列出在nats流中发布的消息,以了解哪些消息未被识别。
我已经尝试过查看nats在其文档中建议的admin api,但是它没有指定是否可以这样做。
我也看过jetstream library for go,用它我可以得到关于流和它们的消费者的一般信息,但不能得到没有被确认的消息,我没有看到任何功能给予我我所需要的。
有没有人已经这样做了,无论编程语言?

z31licg0

z31licg01#

确认绑定到特定的consumer,而不是stream
您可以从consumer信息(确切地说,确认下限)中得出确认的状态:

nats consumer info
State:

   Last Delivered Message: Consumer sequence: 8 Stream sequence: 158 Last delivery: 13m59s ago
     Acknowledgment floor: Consumer sequence: 4 Stream sequence: 154 Last Ack: 13m59s ago
         Outstanding Acks: 2 out of maximum 1,000
     Redelivered Messages: 0
     Unprocessed Messages: 42
            Waiting Pulls: 0 of maximum 512

在NATSCLI和大多数客户端库中都有,但是没有办法直接看到确认消息的列表。

相关问题