From f4caabf92399f00edcb66193be526ca80fde1f81 Mon Sep 17 00:00:00 2001
From: puru <purushotham.p@navi.com>
Date: Thu, 10 Oct 2024 16:07:43 +0530
Subject: [PATCH] DE-3386 | Redirecting litmus events to new topic

---
 lib/RequestHandler.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/RequestHandler.go b/lib/RequestHandler.go
index 05e2079..8c492f4 100644
--- a/lib/RequestHandler.go
+++ b/lib/RequestHandler.go
@@ -81,7 +81,7 @@ func (wp *WorkerPool) processRequest(request RequestObject) {
 	topicFromSource := getTopicFromSource(source)
 
 	message := &sarama.ProducerMessage{
-		Topic: getTopicFromSource(source),
+		Topic: topicFromSource,
 		Value: sarama.ByteEncoder(recordValue),
 	}