chore: Added more logs for blob ingester (#18287)

PostHog · Oct 31, 2023 · 8c173e6 · 8c173e6
1 parent 61cf6d8
commit 8c173e6
Showing 1 changed file with 24 additions and 0 deletions.
diff --git a/plugin-server/src/main/ingestion-queues/session-recording/session-recordings-consumer.ts b/plugin-server/src/main/ingestion-queues/session-recording/session-recordings-consumer.ts
@@ -759,11 +759,35 @@ export class SessionRecordingIngester {
                 const lastKnownCommit = metrics.lastKnownCommit ?? -1
 
                 if (!highestOffsetToCommit) {
+                    if (partition === 101) {
+                        status.warn('🤔', 'blob_ingester_consumer - no highestOffsetToCommit for partition', {
+                            blockingSession: potentiallyBlockingSession?.sessionId,
+                            blockingSessionTeamId: potentiallyBlockingSession?.teamId,
+                            partition: partition,
+                            lastKnownCommit,
+                            lastMessageOffset: metrics.lastMessageOffset,
+                            highestOffsetToCommit,
+                        })
+                    }
                     return
                 }
 
                 // If the last known commit is more than or equal to the highest offset we want to commit then we don't need to do anything
                 if (lastKnownCommit >= highestOffsetToCommit) {
+                    if (partition === 101) {
+                        status.warn(
+                            '🤔',
+                            'blob_ingester_consumer - last known commit was higher than the highestOffsetToCommit',
+                            {
+                                blockingSession: potentiallyBlockingSession?.sessionId,
+                                blockingSessionTeamId: potentiallyBlockingSession?.teamId,
+                                partition: partition,
+                                lastKnownCommit,
+                                lastMessageOffset: metrics.lastMessageOffset,
+                                highestOffsetToCommit,
+                            }
+                        )
+                    }
                     return
                 }