Hsinchang

I had added MergeAll method for batch upsert operation.

AccessviolationException occurred with race condition when pulling agent rebalancing

1

https://github.com/jonathansant/Orleans.Streams.Kafka/blob/f5e89b53195cbca6d9e22b8d2e2d43cb35d881de/Orleans.Streams.Kafka/Core/KafkaAdapterReceiver.cs#L139 I think it would be better to delay `_consumer.Dispose` when `KafkaAdapterReceiver.Shutdown` be invoking.

implicit subscription not working on heterogeneous silos

6

I have a heterogeneous silos environment. Silo1: GrainA class with an implicit subscription on the namespace 'topic' Silo2: without GrainA When the associated queue's pull-agent was activated on Silo2, the...