See my previous updated answer. You don't need to create a new SinkRecord, you are getting already your values from Kafka in the SinkRecord:
You need to extract the valeus from the record (step 2 I mentioned in previous post). Now I know your next question is how do you extract the values from a SinkRecord? There the Kafka API is coming in for help. Look at it and try to use it to get your values out of the SinkRecord. -- Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p13282.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
