Also needed to update here...

PostHog · Mar 18, 2024 · 0de49eb · 0de49eb
1 parent 14ecf3f
commit 0de49eb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugin-server/src/main/ingestion-queues/batch-processing/each-batch-ingestion.ts b/plugin-server/src/main/ingestion-queues/batch-processing/each-batch-ingestion.ts
@@ -255,7 +255,7 @@ async function emitToOverflow(queue: IngestionConsumer, kafkaMessages: Message[]
             queue.pluginsServer.kafkaProducer.produce({
                 topic: KAFKA_EVENTS_PLUGIN_INGESTION_OVERFLOW,
                 value: message.value,
-                key: null, // No locality guarantees in overflow
+                key: message.key,
                 headers: message.headers,
                 waitForAck: true,
             })