How to implement StreamSingleTupleExtractor in Kafka connect Ignite sink?

[ignitedFox <bl...@gmail.com>]

Hi,

I am using Kafka connect Igniite sink. I have JSON records in kafka like;



I would like to make a tuple extractor, so that the **BUS_ID** will act as
key in Ignite. From the documentation, I have noted that "If you need to
create an Ignite key from a Kafka value, implement
StreamSingleTupleExtractor and specify it as 'singleTupleExtractorCls'". I
want to create an extractor and implement it like this. It will be really
helpful if somebody kindly tell me how to create one, and how to implement
this.

Thanks in advance.



--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-implement-StreamSingleTupleExtractor-in-Kafka-connect-Ignite-sink-tp13166.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: How to implement StreamSingleTupleExtractor in Kafka connect Ignite sink?

[Humphrey <hm...@gmail.com>]

See answers in the following thread. 

http://apache-ignite-users.70518.x6.nabble.com/Kindly-tell-me-where-to-find-these-jar-files-td12649.html



--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-implement-StreamSingleTupleExtractor-in-Kafka-connect-Ignite-sink-tp13166p13199.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.