Aaron Stannard comments

Results 761 comments of


                                            Aaron Stannard

Bump dotnet-sdk from 9.0.302 to 9.0.306

@dependabot rebase

Do `IConsumer.Pause` and `IConsumer.Resume` not take immediate effect?

It looks like the underlying librdkafka operations were, at one point, asynchronous but are now synchronous? https://github.com/confluentinc/librdkafka/issues/2455#issuecomment-521165132

Do `IConsumer.Pause` and `IConsumer.Resume` not take immediate effect?

Yeah it looks like in this PR that behavior was introduced? https://github.com/confluentinc/librdkafka/pull/2473

Add DistributedPubSub ping-pong benchmark

Think we could get this integrated into Akka.Cluster.Benchmarks instead @Arkatufus ?

Cache: failed to detect dependencies on real run

Looks like https://github.com/petabridge/Incrementalist/issues/350 was the underlying issue. For now, I think I'm just going to disable caching.

Cache: failed to detect dependencies on real run

Deleted the cache functionality

Emit heartbeat and remoting metrics periodically to the `EventStream`

Want to know: 1. Who we are heartbeating to (THIS VALUE WILL CHANGE) 2. And how long it took them to reply back, on average - the PhiAccrualDetector, which we...

Emit heartbeat and remoting metrics periodically to the `EventStream`

I would also an event that measures the rough throughput of Akka.Remote, but that will take a bit more work to implement

Akka.Cluster.Sharding: dealing with `remember-entities` and actors who can't start up correctly

Additional idea / requirement for this mentioned by @jshave in Discord: `Having different strategies would be nice. Maybe an exponential back off or something the developer could specify?` The thread...

Akka.Cluster.Sharding: dealing with `remember-entities` and actors who can't start up correctly

> we'll need to make a custom SupervisorStrategy for the Shard actors that can notifies the Shard when an entity was restarted excessively I think this is the right idea...