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/16 01:43:00 UTC
[jira] [Updated] (IGNITE-4199) Functionality to extract keys from
values when sinking data from kafka topics
[ https://issues.apache.org/jira/browse/IGNITE-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Roman Shtykh updated IGNITE-4199:
---------------------------------
Fix Version/s: (was: 1.7)
1.8
> Functionality to extract keys from values when sinking data from kafka topics
> -----------------------------------------------------------------------------
>
> Key: IGNITE-4199
> URL: https://issues.apache.org/jira/browse/IGNITE-4199
> Project: Ignite
> Issue Type: Improvement
> Components: streaming
> Affects Versions: 1.7
> Environment: linux, centos 7
> Reporter: austin solomon
> Assignee: Roman Shtykh
> Priority: Blocker
> Labels: performance
> Fix For: 1.8
>
>
> I have a use case where I am reading a text file using kafka's FileStreamSource connector and sinking the data to Ignite's cache.
> I got an error while doing this
> Error: ERROR Failed to stream a record with null key!
> (org.apache.ignite.stream.kafka.connect.IgniteSinkTask:96)
> When I printed the streamed record i got the following result : key=null
> SinkRecord{kafkaOffset=2, timestampType=CreateTime} ConnectRecord{topic='ignitetest', kafkaPartition=2, key=null, value=k1,v1, timestamp=1478690650016}
> I wish to have a functionality to extracting keys from values or any work around.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)