diff --git a/shared/services/RedisStreamService.ts b/shared/services/RedisStreamService.ts
index 54abc05..f9e2f8a 100644
--- a/shared/services/RedisStreamService.ts
+++ b/shared/services/RedisStreamService.ts
@@ -27,6 +27,7 @@ export class RedisStreamService {
         await this.client.connect();
         setInterval(() => {
             console.log('Processed:', RedisStreamService.processed, '/s');
+            RedisStreamService.processed = 0;
         }, 1000)
 
     }