You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on May 8, 2021. It is now read-only.
I have code that does source reader throttling when a hot conductor is backlogged. However it is not enabled, as it hasn't been tested.
A test will require 2 machines/JVMs each reading from a source. On of the JVMs should backlog an a key and the test must make sure that the source reader on the other JVM slows down.
The text was updated successfully, but these errors were encountered:
I have code that does source reader throttling when a hot conductor is backlogged. However it is not enabled, as it hasn't been tested.
A test will require 2 machines/JVMs each reading from a source. On of the JVMs should backlog an a key and the test must make sure that the source reader on the other JVM slows down.
The text was updated successfully, but these errors were encountered: