i am following bellow step to process data
my query is do i need simultaneously run both scala stream collector and Stream enrich steps in my CLI inorder to push the events from kinesis stream (kinesis S3) to S3 bucket?
because when i run command to move event from kinesis S3 to S3 bucket it is taking more time to complete and sometimes it will run within minutes.
Please let us know the overall detailed structure how it is designed.
Because we are failing to run the process in most of the times.