rust/hyperswitch
1
0
Fork 0
mirror of https://github.com/juspay/hyperswitch.git synced 2025-10-29 17:19:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(multitenancy): remove tenant id from redis stream key of kafkaStore (#4916)

Browse Source
This commit is contained in:
Jagan
2024-06-10 19:12:54 +05:30
committed by GitHub
parent e3e31f392b
commit 9c7dcbe1a0
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
crates/router/src/db/kafka_store.rs
View File

@ -1109,9 +1109,8 @@ impl QueueInterface for KafkaStore {
entry_id: &RedisEntryId, entry_id: &RedisEntryId,
fields: Vec<(&str, String)>, fields: Vec<(&str, String)>,
) -> CustomResult<(), RedisError> { ) -> CustomResult<(), RedisError> {
let stream_name = format!("{}_{}", &self.tenant_id.0, stream);
self.diesel_store self.diesel_store
.stream_append_entry(&stream_name, entry_id, fields) .stream_append_entry(stream, entry_id, fields)
.await .await
} }