Increase worker count

brave-intl · Jun 4, 2024 · f0fa6ff · f0fa6ff
1 parent 06f8cdf
commit f0fa6ff
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, 300)
 	ctx := context.Background()
 	go processMessagesIntoBatchPipeline(ctx, topicMappings, reader, batchPipeline, logger)
 	for {