I replied in the new thread you made above. Look in Kafka how to extract the values you want from the SinkRecord you are getting and map those to your Object you want to store in Ignite. So for example you extract the BUS_ID from the SinkRecord (look in the kafka api how to do that) and you map that to they key. Same you do for the other fields and map them to the object you want to store in Ignite.
-- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Kindly-tell-me-where-to-find-these-jar-files-tp12649p13228.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
