Hi everyone, I've submitted KIP-901, which adds an overloaded Task#stop(boolean connectorDeleted) method to the public Kafka Connect APIs:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-901%3A+Add+connectorDeleted+flag+when+stopping+tasks This KIP can be seen as a companion (or counterpart) of KIP-883, which aims to provide the same feature but at the Connector level (there's a separate discussion thread on this list). The KIP also supersedes "KIP-419: Safely notify Kafka Connect SourceTask is stopped". The main goal is to let the task being stopped that it is due to the connector being deleted, so the task can perform any cleanup actions as part of the connector's deletion process. I look forward for your feedback and comments. Thanks! Hector
