From be0be6ce61e2230b1c134aadf5dfa99f2d5243d3 Mon Sep 17 00:00:00 2001 From: Ildar Nurislamov Date: Wed, 15 Nov 2023 10:46:05 +0400 Subject: [PATCH] bulker: ingest: always use multithreaded topic --- bulkerapp/app/router.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/bulkerapp/app/router.go b/bulkerapp/app/router.go index e79be1f..4127b9c 100644 --- 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() }