Hey y'all, please review the following small proposal: https://cwiki.apache.org/confluence/display/KAFKA/KIP-762%3A+Delete+Committed+Connect+Records
The idea is to enable Source->Sink pipelines to clean up after themselves by automatically truncating intermediate topics. Ryanne