[
https://issues.apache.org/jira/browse/KAFKA-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169907#comment-16169907
]
Dhananjay Patkar commented on KAFKA-4714:
-----------------------------------------
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)
