...
After some code analysis, we determined that there wasn't an existing API that a Connector could use to determine that the task was about to be shut down for a rebalance. After some thought we decided that this was a problem more generally about giving connectors the information about the state of the world outside the connector such that they could make intelligent decisions about how to behave in preCommit
. Giving this information to a connector gives developers writing connectors options to change their behavior if a rebalance or shutdown is pending.
To achieve this we We would like to add such an API so that the preCommit
hook of a Connector can decide if it should behave differently because the task is actively trying to shut down.
...