From 9c7dcbe1a042f92dbdd74ec138b56e09fd604a27 Mon Sep 17 00:00:00 2001
From: Jagan <jaganelavarasan@gmail.com>
Date: Mon, 10 Jun 2024 19:12:54 +0530
Subject: [PATCH] fix(multitenancy): remove tenant id from redis stream key of
 kafkaStore (#4916)

---
 crates/router/src/db/kafka_store.rs | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/crates/router/src/db/kafka_store.rs b/crates/router/src/db/kafka_store.rs
index c360b41a6c..0545191318 100644
--- a/crates/router/src/db/kafka_store.rs
+++ b/crates/router/src/db/kafka_store.rs
@@ -1109,9 +1109,8 @@ impl QueueInterface for KafkaStore {
         entry_id: &RedisEntryId,
         fields: Vec<(&str, String)>,
     ) -> CustomResult<(), RedisError> {
-        let stream_name = format!("{}_{}", &self.tenant_id.0, stream);
         self.diesel_store
-            .stream_append_entry(&stream_name, entry_id, fields)
+            .stream_append_entry(stream, entry_id, fields)
             .await
     }