[jira] [Created] (IGNITE-4199) Functionality to extract keys from values when sinking data from kafka topics

["austin solomon (JIRA)" <ji...@apache.org>]

austin solomon created IGNITE-4199:
--------------------------------------

             Summary: 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
            Priority: Blocker
             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)