explicit message count

plugin-server/src/worker/ingestion/process-event.ts

@@ -282,6 +282,7 @@ export interface SummarizedSessionRecordingEvent {
     console_error_count: number
     size: number
     event_count: number
+    message_count: number
 }
 
 export const createSessionReplayEvent = (
@@ -359,6 +360,7 @@ export const createSessionReplayEvent = (
         console_error_count: Math.trunc(consoleErrorCount),
         size: Math.trunc(Buffer.byteLength(JSON.stringify(events), 'utf8')),
         event_count: Math.trunc(events.length),
+        message_count: 1,
     }
 
     return data

posthog/models/session_replay_event/sql.py

@@ -28,7 +28,8 @@
     console_warn_count Int64,
     console_error_count Int64,
     size Int64,
-    event_count Int64
+    event_count Int64,
+    message_count Int64
 ) ENGINE = {engine}
 """
 
@@ -128,7 +129,7 @@
 sum(console_error_count) as console_error_count,
 sum(size) as size,
 -- we can count the number of kafka messages instead of sending it explicitly
-count(*) as message_count,
+sum(message_count) as message_count,
 sum(event_count) as event_count,
 max(_timestamp) as _timestamp
 FROM {database}.kafka_session_replay_events