From 456de207e8f2991c492ba038ad6031aa97b178fd Mon Sep 17 00:00:00 2001 From: Ben White Date: Wed, 4 Sep 2024 17:23:55 +0200 Subject: [PATCH] Fix --- plugin-server/src/cdp/cdp-consumers.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/plugin-server/src/cdp/cdp-consumers.ts b/plugin-server/src/cdp/cdp-consumers.ts index 3c26cf00ef75c..499b030e61564 100644 --- 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,