We have configured data flow with source with dataset to browse the message from kafka topic and destination shape we have configured an activity to process the message.
When the code moved to production, data flow run failed to process the incoming message request and during run time pega is checking activity in particular user ruleset instead of application ruleset
As the activity is not found in that particular user ruleset and record gets failed with rule not found error