fix

PostHog · Mar 28, 2024 · 1b37861 · 1b37861
1 parent 5603fd9
commit 1b37861
Showing 1 changed file with 20 additions and 14 deletions.
diff --git a/plugin-server/tests/main/ingestion-queues/session-recording/utils.test.ts b/plugin-server/tests/main/ingestion-queues/session-recording/utils.test.ts
@@ -212,13 +212,16 @@ describe('session-recording utils', () => {
                 [
                     [
                         {
-                            messages: [
-                                expectedIngestionWarningMessage({
-                                    libVersion: '1.74.0',
-                                    minorVersion: 74,
-                                }),
-                            ],
-                            topic: 'clickhouse_ingestion_warnings_test',
+                            kafkaMessage: {
+                                messages: [
+                                    expectedIngestionWarningMessage({
+                                        libVersion: '1.74.0',
+                                        minorVersion: 74,
+                                    }),
+                                ],
+                                topic: 'clickhouse_ingestion_warnings_test',
+                            },
+                            waitForAck: true,
                         },
                     ],
                 ],
@@ -229,13 +232,16 @@ describe('session-recording utils', () => {
                 [
                     [
                         {
-                            messages: [
-                                expectedIngestionWarningMessage({
-                                    libVersion: '1.32.0',
-                                    minorVersion: 32,
-                                }),
-                            ],
-                            topic: 'clickhouse_ingestion_warnings_test',
+                            kafkaMessage: {
+                                messages: [
+                                    expectedIngestionWarningMessage({
+                                        libVersion: '1.32.0',
+                                        minorVersion: 32,
+                                    }),
+                                ],
+                                topic: 'clickhouse_ingestion_warnings_test',
+                            },
+                            waitForAck: true,
                         },
                     ],
                 ],