Full design doc
Implement a rate controller for receiver-based InputDStreams that estimates a maximum rate and sends it to each receiver supervisor.
Implement the DirectKafkaRateController
Implement a PIDRateEstimator
Implement a mechanism to send a new rate from the driver to the block generator
Throttle DStreams dynamically through back-pressure information
[Github] Pull Request #7600 (dragos)