Hi, I have a Reliable Custom Receiver storing messages into Spark. Is there way how to prevent my receiver from storing more messages into Spark when the Scheduling Delay reaches a certain threshold?
Possible approaches: #1 Does Spark block on the Receiver.store(messages) call to prevent storing more messages and overflowing the system? #2 How to obtain the Scheduling Delay in the Custom Receiver, so that I can implement the feature. Thanks, Mike
