Hi all, I'd like to start a vote on KIP-793 which enables sink connector implementations to be used with SMTs that mutate the topic / partition / offset information of a record.
KIP - https://cwiki.apache.org/confluence/display/KAFKA/KIP-793%3A+Allow+sink+connectors+to+be+used+with+topic-mutating+SMTs Discussion thread - https://lists.apache.org/thread/dfo3spv0xtd7vby075qoxvcwsgx5nkj8 Thanks, Yash