One minor thing, the Transformer interface probably needs a close() method (i.e. the opposite of initialize). This would be used for any transformer that uses a resource like a file/socket/db connection/etc that needs to be closed. You usually don't need this but when you do need it you really need it.
-Jay On Mon, Jul 11, 2016 at 1:47 PM, Nisarg Shah <snis...@gmail.com> wrote: > Hello, > > This KIP < > https://cwiki.apache.org/confluence/display/KAFKA/KIP-66:+Add+Kafka+Connect+Transformers+to+allow+transformations+to+messages> > is for KAFKA-3209 <https://issues.apache.org/jira/browse/KAFKA-3209>. > It’s about capabilities to transform messages in Kafka Connect. > > Some design decisions need to be taken, so please advise me on the same. > Feel free to express any thoughts or concerns as well. > > Many many thanks to Ewen Cheslack-Postava. > > -Nisarg
