From 06f8cdf2345e63d0289ddbd5443ddfe943eaa46c Mon Sep 17 00:00:00 2001 From: Jackson Date: Tue, 4 Jun 2024 11:46:51 -0400 Subject: [PATCH] Increase workers --- kafka/main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/main.go b/kafka/main.go index 005c102e..c0868872 100644 --- a/kafka/main.go +++ b/kafka/main.go @@ -86,7 +86,7 @@ func StartConsumers(providedServer *server.Server, logger *zerolog.Logger) error reader := newConsumer(topics, adsConsumerGroupV1, logger) - batchPipeline := make(chan *MessageContext, 100) + batchPipeline := make(chan *MessageContext, 200) ctx := context.Background() go processMessagesIntoBatchPipeline(ctx, topicMappings, reader, batchPipeline, logger) for {