bulker: ingest: always use multithreaded topic

jitsucom · Nov 15, 2023 · be0be6c · be0be6c
1 parent a8b2477
commit be0be6c
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/bulkerapp/app/router.go b/bulkerapp/app/router.go
@@ -315,10 +315,11 @@ func (r *Router) IngestHandler(c *gin.Context) {
 	for _, destination := range stream.AsynchronousDestinations {
 		messageCopy := ingestMessage
 		messageCopy.ConnectionId = destination.ConnectionId
-		multithreading, ok := destination.Options["multithreading"].(bool)
+		//multithreading, ok := destination.Options["multithreading"].(bool)
+		multithreading := true
 		topic := r.config.KafkaDestinationsTopicName
 		messageKey := messageCopy.ConnectionId
-		if ok && multithreading {
+		if multithreading {
 			topic = r.config.KafkaDestinationsTopicMultiThreadedName
 			messageKey = uuid.New()
 		}