ignite-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Roman Shtykh (JIRA)" <j...@apache.org>
Subject [jira] [Assigned] (IGNITE-4199) Functionality to extract keys from values when sinking data from kafka topics
Date Thu, 10 Nov 2016 01:43:58 GMT

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

Roman Shtykh reassigned IGNITE-4199:
------------------------------------

    Assignee: Roman Shtykh

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

Mime
View raw message