If I understand correctly, you don't really need the whole notion of acknowledgement (subscription). When the web client connects, it needs to receive the last N messages (What happens from there after?)
How about using a non-durable subscription - they only live as long as the broker is not restarted and the topic has not moved between them (load balancer). If the subscription vanishes, you just recreate your whole buffer from scratch? Also take a look at Reader interface: https://pulsar.apache.org/docs/2.11.x/concepts-clients/#reader-interface On Tue, Jan 24, 2023 at 11:47 AM Niclas Hedhman <nic...@hedhman.org> wrote: > On 2023-01-24 10:29, Niclas Hedhman wrote: > > What a mess up! I already had it changed to "persistent://" and I > > misread "non-partitioned" in my server code. > > > > So, my topics ARE persistent already, non-partitioned (to save > > space?). The rest of my original post still applies. > > non-partitioned so I can do > > seekError := reader.SeekByTime(hourAgo) > > So additional question; Should I try to stick with this approach or rely > on RetentionPolicies? > > > >
