We are using Data Flow for AWS Kinesis integration and we are able to successfully able to receive the messages.

Once message is received we are processing these messages using activity to change the stage of Case. 

During this process if system is not able to take lock then our expectations is Data flow should throw an error based on the activity error and should retry automatically. 

We have observed that even though there is an error in activity Data Flow is showing all records as successful. 

Can someone explain how data flow retry works and how to pass on error from activity to Data flow so that data flow shows records as failure and retry automatically?