[ https://issues.apache.org/jira/browse/KAFKA-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169907#comment-16169907 ]
Dhananjay Patkar edited comment on KAFKA-4714 at 9/18/17 11:53 AM: ------------------------------------------------------------------- Currently on the sink side, transformations are applied before consuming record. ??For sink connectors, transformations are applied on the collection of SinkRecord before being provided to SinkTask.put().?? Is it possible to get original ConnectRecord object in consumer task? If this is not available then ,can we preserve original message or is it possible to add support for post "SinkTask.put()" transformation? was (Author: dhananjaydp): Currently on the sink side, transformations are applied on the consumed record. ??For sink connectors, transformations are applied on the collection of SinkRecord before being provided to SinkTask.put().?? Is it possible to get original ConnectRecord object in consumer task? If this is not available then ,can we preserve original message or is it possible to add support for post "SinkTask.put()" transformation? > Implement remaining KIP-66 SMTs > ------------------------------- > > Key: KAFKA-4714 > URL: https://issues.apache.org/jira/browse/KAFKA-4714 > Project: Kafka > Issue Type: Bug > Components: KafkaConnect > Reporter: Ewen Cheslack-Postava > Assignee: Ewen Cheslack-Postava > Fix For: 0.11.0.0 > > > Three didn't make it for the 0.10.2.0 release: Flatten, Cast, and > TimestampConverter. -- This message was sent by Atlassian JIRA (v6.4.14#64029)