Hi,
We are currently investigating why some of our code that uses stream subscriptions seems to stall.
What happens is that we subscribe to some stream that already contains data, do some processing that emits new events into other streams, and at some point, it seems like the whole source stalls.
Even if we restart EventStore, the client won’t notice and will not wake up.
We use akka-stream using code such as
Source
.fromPublisher(connection.streamPublisher(
streamId = streamId,
fromNumberExclusive = from,
infinite = infinite
))
Is there anything you would suggest we try to debug the problem? Any log we should be looking at? any config we could tweak?
Thanks,
Sami