diff --git a/worker_bouncer.js b/worker_bouncer.js
index 35535aa..57f5c03 100644
--- a/worker_bouncer.js
+++ b/worker_bouncer.js
@@ -79,6 +79,9 @@ parentPort.on('message', m => {
           filters[fn].limit = ws.forcedLimit;
       }
 
+      if (max_known_events && getFilterLimit(filter) > max_known_events)
+        filter.limit = max_known_events;
+
       ws.subs[origID] = filters;
       ws.events[origID] = new Set();
       ws.pause_subs.delete(origID);