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

hfyxw5xn 于 2022-12-20 发布在 Go

关注(0)|答案(1)|浏览(259)

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

来源：https://stackoverflow.com/questions/74491813/how-to-list-the-messages-of-a-nats-jetstream-and-know-if-they-were-acknowledged

1条答案

按热度按时间

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和大多数客户端库中都有，但是没有办法直接看到确认消息的列表。

赞(0）回复(0）举报 2022-12-20

我来回答

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

1条答案

相关问题

热门标签

最新问答

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

1条答案

相关问题

热门标签

最新问答

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