Benjamin Petit

Unfortunately, the issue is more difficult to fix than expected. The logic in `PersistentStreamPullingAgent` is a bit complicated, and the the risk is too high to introduce another bug to...

Sorry I haven't had the time to look at your issue yet. Are you 100% sure that your silos are shutting down gracefully on rolling upgrade? Do you see warning/errors...

When using `MemoryStream`, the `SequenceNumber` starts from the `DateTime.UtcNow.Ticks` value when the `MemoryStreamQueueGrain` was first activated, so it's expected that's not 0 or a low number. `SequenceNumber` is then incremented...

We want to throw `QueueCacheMissException` if we cannot guarantee that we didn't miss any event. `QueueCacheMissException` should be handled by the application code, and should be read as "we may...

I think adding compression to the serializer can be a good idea. I think it could be added to the existing `IGrainStorageSerializer` interface. It could benefits all providers that are...

I didn't notice that your PR is targeting 3.x. Yes, if we end up implementing something like that, that will be in 8.

That's a very good point, we should add the same config methods for the built-in directory, so you can use it with a name

It seems like a race condition? Not sure how it could happen...

Do you have access to the PullingAgents logs?

The pulling agent manager should use a category like this `Orleans.Streams.PersistentStreamPullingManager.[YourProviderName]`. The pulling agent should have this category: `Orleans.Streams.[YourProviderName]`. I am interested in any logs with loglevel Info or more,...