Deactivate consumer on write exception.

backend/src/Squidex.Infrastructure/EventSourcing/Grains/BatchSubscriber.cs

@@ -97,6 +97,8 @@ namespace Squidex.Infrastructure.EventSourcing.Grains
             {
                 await foreach (var task in taskQueue.Reader.ReadAllAsync(completed.Token))
                 {
+                    var scheduler = TaskScheduler.Current;
+
                     var sender = eventSubscription?.Sender;
 
                     if (sender == null)

backend/src/Squidex.Infrastructure/EventSourcing/Grains/EventConsumerGrain.cs

@@ -227,6 +227,14 @@ namespace Squidex.Infrastructure.EventSourcing.Grains
                     await state.WriteAsync();
                 }
             }
+            catch (Exception ex)
+            {
+                Unsubscribe();
+
+                State = State.Stopped(ex);
+
+                DeactivateOnIdle();
+            }
             finally
             {
                 semaphore.Release();