与StartAtSequence、StartWithLastReceived等其他工具相比,我对StartAt subscription option的需求/意义感到有点困惑。
我试图深入研究Java客户端文档,但也没有帮助--比如option cannot be set,但是it is gettable
感谢您的投入!
发布于 2019-11-23 03:37:41
Abhishek
您应该已经看过Go README.md,因为您实际上对Go客户端感兴趣,而不是Java客户端:-)
这里有一个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中找到有关订阅的更多信息。
希望这能有所帮助。
https://stackoverflow.com/questions/59000472
复制相似问题