kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dhananjay Patkar (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (KAFKA-4714) Implement remaining KIP-66 SMTs
Date Mon, 18 Sep 2017 11:54:00 GMT

    [ 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)

Mime
View raw message