Merge pull request #726 from brave-intl/fix/revert-num-cpu

fix: revert CPU constraint

kafka/main.go

@@ -7,7 +7,6 @@ import (
 	"fmt"
 	"io"
 	"os"
-	"runtime"
 	"strings"
 	"time"
 
@@ -87,11 +86,7 @@ func StartConsumers(providedServer *server.Server, logger *zerolog.Logger) error
 
 	reader := newConsumer(topics, adsConsumerGroupV1, logger)
 
-	// Each message in batchPipeline is associated with goroutine doing
-	// CPU-intensive cryptography, so limit the channel capacity by CPU cores
-	// plus some extra buffer to account for IO that a processor may potentially
-	// do.
-	batchPipeline := make(chan *MessageContext, runtime.NumCPU()+2)
+	batchPipeline := make(chan *MessageContext, 100)
 	ctx := context.Background()
 	go processMessagesIntoBatchPipeline(ctx, topicMappings, reader, batchPipeline, logger)
 	for {