Fix

PostHog · Sep 4, 2024 · 456de20 · 456de20
1 parent 60f36b9
commit 456de20
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugin-server/src/cdp/cdp-consumers.ts b/plugin-server/src/cdp/cdp-consumers.ts
@@ -296,7 +296,7 @@ abstract class CdpConsumerBase {
             // queuedMinMessages: this.hub.KAFKA_QUEUE_SIZE,
             consumerMaxWaitMs: this.hub.KAFKA_CONSUMPTION_MAX_WAIT_MS,
             consumerErrorBackoffMs: this.hub.KAFKA_CONSUMPTION_ERROR_BACKOFF_MS,
-            fetchBatchSize: 10, // this.hub.INGESTION_BATCH_SIZE,
+            fetchBatchSize: this.hub.INGESTION_BATCH_SIZE,
             batchingTimeoutMs: this.hub.KAFKA_CONSUMPTION_BATCHING_TIMEOUT_MS,
             topicCreationTimeoutMs: this.hub.KAFKA_TOPIC_CREATION_TIMEOUT_MS,
             topicMetadataRefreshInterval: this.hub.KAFKA_TOPIC_METADATA_REFRESH_INTERVAL_MS,