On 2023-01-25 13:59, Asaf Mesika wrote:
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?)
Keep "reading" messages and update UI as they arrive.
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
Ah!! I use Reader... I wasn't clear (to me) that it doesn't use acknowledgements. Should have realized that, pretty obvious.
So, thanks... I now have the Pulsar side of the equation working, and need to get the mechanics of Grafana Streaming to play along.
Niclas
