我正在通过 WebSockets 使用 Apache Pulsar。当我使用阅读器从主题中获取数据时,如果我确认消息,它们会从主题中删除吗?我为该主题的命名空间设置了保留期,如下所示:
pulsar-admin namespaces set-retention public/default \
--size 1T \
--time -1
当我第一次使用阅读器时,我的设置有效;随着数据进入主题,我能够阅读它。但是为什么无法使用阅读器再次访问这些消息。
网址是:
ws://someEndPoint:8080/ws/v2/reader/persistent/public/default/topicName?messageId=earliest&receiverQueueSize=100000