diff --git a/.run/Plugin Server.run.xml b/.run/Plugin Server.run.xml
index 5fb587554b4..4ec58fe1f43 100644
--- a/.run/Plugin Server.run.xml	
+++ b/.run/Plugin Server.run.xml	
@@ -12,9 +12,11 @@
       <env name="KAFKA_HOSTS" value="localhost:9092" />
       <env name="OBJECT_STORAGE_ENABLED" value="True" />
       <env name="SESSION_RECORDING_ENABLE_OFFSET_HIGH_WATER_MARK_PROCESSING" value="true" />
+      <env name="SESSION_RECORDING_KAFKA_BATCH_SIZE" value="200" />
       <env name="SESSION_RECORDING_MAX_BUFFER_AGE_SECONDS" value="180" />
       <env name="SESSION_RECORDING_SUMMARY_INGESTION_ENABLED_TEAMS" value="all" />
       <env name="WORKER_CONCURRENCY" value="2" />
+      <env name="SESSION_RECORDING_KAFKA_QUEUE_SIZE" value="600" />
     </envs>
     <method v="2" />
   </configuration>
diff --git a/plugin-server/src/main/ingestion-queues/session-recording/blob-ingester/realtime-manager.ts b/plugin-server/src/main/ingestion-queues/session-recording/blob-ingester/realtime-manager.ts
index c561e631789..89d2ebbe792 100644
--- a/plugin-server/src/main/ingestion-queues/session-recording/blob-ingester/realtime-manager.ts
+++ b/plugin-server/src/main/ingestion-queues/session-recording/blob-ingester/realtime-manager.ts
@@ -1,4 +1,5 @@
 import { captureException } from '@sentry/node'
+import { randomUUID } from 'crypto'
 import { Redis } from 'ioredis'
 import { EventEmitter } from 'node:events'
 
@@ -143,7 +144,28 @@ export class RealtimeManager extends EventEmitter {
 
         try {
             await this.run(`clearAllMessages ${key} `, async (client) => {
-                return client.del(key)
+                /**
+                 * We could delete the key here but (https://redis.io/commands/del/) del is O(M)
+                 * where M is the number of items in the sorted set, for a large buffer this could be
+                 * a lot of work.
+                 *
+                 * Whereas RENAME (https://redis.io/commands/rename/) is O(1)
+                 * (_almost_ always O(1))
+                 * """
+                 *  If newkey already exists it is overwritten, when this happens RENAME executes an implicit DEL operation,
+                 *  so if the deleted key contains a very big value it may cause high latency
+                 *  even if RENAME itself is usually a constant-time operation.
+                 *  """
+                 *  So, we rename the key to expired-<key>-<uuid>, so that it can't possibly clash
+                 *  and let it expire
+                 */
+                const pipeline = client.pipeline()
+                const newKey = `expired-${key}-${randomUUID()}`
+                pipeline.rename(`${key}`, newKey)
+                // renaming shouldn't affect the existing TTL
+                // but, we set one anyway to be sure
+                pipeline.expire(newKey, 1)
+                return pipeline.exec()
             })
         } catch (error) {
             captureException(error, { tags: { teamId, sessionId }, extra: { key } })