NATS 流媒体 "StartAt" 订阅选项
NATS streaming "StartAt" subscription option
与 StartAtSequence
、StartWithLastReceived
等其他人相比,我对 StartAt
subscription option 的 requirement/significance 感到有点困惑。
我试图深入研究 Java 客户端文档,但这也无济于事 - 例如 option cannot be set, but it is gettable
感谢输入!
阿布舍克,
您应该看看 Go README.md,因为看起来您实际上对 Go 客户端感兴趣,而不是 Java :-)
这里是link到start position。
如您所知,StartAtSequence 用于在给定的序列号处创建订阅,而 StartWithLastReceived 表示服务器应发送最后一个。
StartAt() 只是通用选项,您可以在其中传递 pb.StartPosition,它是一个 int32,表示可能的选项:
StartPosition_NewOnly StartPosition = 0
StartPosition_LastReceived StartPosition = 1
StartPosition_TimeDeltaStart StartPosition = 2
StartPosition_SequenceStart StartPosition = 3
StartPosition_First StartPosition = 4
所以你不需要它,只要有你想要的 "Start" 选项功能。
此外,您可以在我们的 doc 中找到有关订阅的更多信息。
希望对您有所帮助。
与 StartAtSequence
、StartWithLastReceived
等其他人相比,我对 StartAt
subscription option 的 requirement/significance 感到有点困惑。
我试图深入研究 Java 客户端文档,但这也无济于事 - 例如 option cannot be set, but it is gettable
感谢输入!
阿布舍克,
您应该看看 Go README.md,因为看起来您实际上对 Go 客户端感兴趣,而不是 Java :-)
这里是link到start position。
如您所知,StartAtSequence 用于在给定的序列号处创建订阅,而 StartWithLastReceived 表示服务器应发送最后一个。
StartAt() 只是通用选项,您可以在其中传递 pb.StartPosition,它是一个 int32,表示可能的选项:
StartPosition_NewOnly StartPosition = 0
StartPosition_LastReceived StartPosition = 1
StartPosition_TimeDeltaStart StartPosition = 2
StartPosition_SequenceStart StartPosition = 3
StartPosition_First StartPosition = 4
所以你不需要它,只要有你想要的 "Start" 选项功能。
此外,您可以在我们的 doc 中找到有关订阅的更多信息。
希望对您有所帮助。