fix(multitenancy): remove tenant id from redis stream key of kafkaSto…

…re (#4916)
juspay · Jun 10, 2024 · 9c7dcbe · 9c7dcbe
1 parent e3e31f3
commit 9c7dcbe
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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
     }