Since you were using the in your worker it's converting the value to a Json format. What you need to do is convert it back and map it to an object. This is working for me. For this to compile you need to put the following dependency on your project with the correct kafka version, the jar is alreay on the classpath of Kafka so you don't need to put extra jars there:
For me the following is working: -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p13450.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
