diff --git a/src/Squidex.Infrastructure.MongoDb/CQRS/Events/PollingSubscription.cs b/src/Squidex.Infrastructure.MongoDb/CQRS/Events/PollingSubscription.cs
index ca95e20de..196809500 100644
--- a/src/Squidex.Infrastructure.MongoDb/CQRS/Events/PollingSubscription.cs
+++ b/src/Squidex.Infrastructure.MongoDb/CQRS/Events/PollingSubscription.cs
@@ -42,6 +42,7 @@ namespace Squidex.Infrastructure.CQRS.Events
         public PollingSubscription(MongoEventStore store, IEventNotifier notifier, IEventSubscriber subscriber, string streamFilter, string position)
         {
             this.notifier = notifier;
+            this.position = position;
             this.store = store;
             this.streamFilter = streamFilter;
             this.subscriber = subscriber;
diff --git a/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs b/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs
index 2536f57d4..12656e586 100644
--- a/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs
+++ b/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs
@@ -188,7 +188,7 @@ namespace Squidex.Infrastructure.CQRS.Events.Actors
         {
             var status = await eventConsumerInfoRepository.FindAsync(eventConsumer.Name);
 
-            eventSubscription = eventStore.CreateSubscription(this, streamFilter: eventConsumer.EventsFilter, position: status.Position);
+            eventSubscription = eventStore.CreateSubscription(this, eventConsumer.EventsFilter, status.Position);
 
             await eventConsumerInfoRepository.StartAsync(eventConsumer.Name);
         }