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.
