This Jira has been LDAP enabled, if you are an ASF Committer, please use your LDAP Credentials to login. Any problems email firstname.lastname@example.org
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)