From 8c173e6bd7d1425d2b68fd0ec64e93cd1238e0a7 Mon Sep 17 00:00:00 2001 From: Ben White Date: Tue, 31 Oct 2023 09:14:08 +0100 Subject: [PATCH] chore: Added more logs for blob ingester (#18287) --- .../session-recordings-consumer.ts | 24 +++++++++++++++++++ 1 file changed, 24 insertions(+) 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 index ec2d32e878a90..3a08c65af9de0 100644 --- 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 }