[ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674120#comment-15674120 ]
Nisarg Shah commented on KAFKA-3209: ------------------------------------ Hey Juan. I have started working on this, have only been busy lately and will start again within a few weeks. You could help though. Have a look at the KIP (link above) and let's discuss suggestions and implementations. > Support single message transforms in Kafka Connect > -------------------------------------------------- > > Key: KAFKA-3209 > URL: https://issues.apache.org/jira/browse/KAFKA-3209 > Project: Kafka > Issue Type: Improvement > Components: KafkaConnect > Reporter: Neha Narkhede > Labels: needs-kip > Fix For: 0.10.2.0 > > > Users should be able to perform light transformations on messages between a > connector and Kafka. This is needed because some transformations must be > performed before the data hits Kafka (e.g. filtering certain types of events > or PII filtering). It's also useful for very light, single-message > modifications that are easier to perform inline with the data import/export. -- This message was sent by Atlassian JIRA (v6.3.4#6332)