You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Roman Shtykh (JIRA)" <ji...@apache.org> on 2016/11/09 06:49:58 UTC

[jira] [Updated] (IGNITE-4198) Ignite Kafka sink connector should have an option to transform Kafka values

     [ https://issues.apache.org/jira/browse/IGNITE-4198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Roman Shtykh updated IGNITE-4198:
---------------------------------
    Description: 
Currently the connector takes a Kafka key and uses it as an Ignite key. However, Kafka keys can be null, and users may want to specify an Ignite key from the value object.

Instead of creating a new transformer interface, I think we can use {{StreamMultipleTupleExtractor}} whenever its implementation is specified by the user in connector config file.

http://apache-ignite-users.70518.x6.nabble.com/Kafka-Failed-to-stream-a-record-with-null-key-td8731.html

  was:
Currently the connector takes a Kafka key and uses it as an Ignite key. However, Kafka keys can be null, and users may want to specify an Ignite key from the value object.

Instead of creating a new transformer interface, I think we can use {{StreamMultipleTupleExtractor}} whenever its implementation is specified by the user in connector config file.


> Ignite Kafka sink connector should have an option to transform Kafka values
> ---------------------------------------------------------------------------
>
>                 Key: IGNITE-4198
>                 URL: https://issues.apache.org/jira/browse/IGNITE-4198
>             Project: Ignite
>          Issue Type: Improvement
>            Reporter: Roman Shtykh
>            Assignee: Roman Shtykh
>
> Currently the connector takes a Kafka key and uses it as an Ignite key. However, Kafka keys can be null, and users may want to specify an Ignite key from the value object.
> Instead of creating a new transformer interface, I think we can use {{StreamMultipleTupleExtractor}} whenever its implementation is specified by the user in connector config file.
> http://apache-ignite-users.70518.x6.nabble.com/Kafka-Failed-to-stream-a-record-with-null-key-td8731.html



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)