Merge pull request #730 from brave-intl/hotfix/cpu-increase

Increase worker count
brave-intl · Jun 4, 2024 · 5b9be47 · 5b9be47
2 parents bc6cad8 + ebc2e8d
commit 5b9be47
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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, 200)
+	batchPipeline := make(chan *MessageContext, 400)
 	ctx := context.Background()
 	go processMessagesIntoBatchPipeline(ctx, topicMappings, reader, batchPipeline, logger)
 	for {