diff --git a/crates/router/src/db/kafka_store.rs b/crates/router/src/db/kafka_store.rs index 6e59e0c95d..0d0ba623a4 100644 --- a/crates/router/src/db/kafka_store.rs +++ b/crates/router/src/db/kafka_store.rs @@ -1288,13 +1288,14 @@ impl MerchantConnectorAccountInterface for KafkaStore { key_store: &domain::MerchantKeyStore, connector_type: common_enums::ConnectorType, ) -> CustomResult, errors::StorageError> { - self.list_enabled_connector_accounts_by_profile_id( - state, - profile_id, - key_store, - connector_type, - ) - .await + self.diesel_store + .list_enabled_connector_accounts_by_profile_id( + state, + profile_id, + key_store, + connector_type, + ) + .await } async fn insert_merchant_connector_account(