ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Humphrey <hmmlo...@gmail.com>
Subject Re: How to solve SinkRecord cannot be cast exception?
Date Wed, 07 Jun 2017 05:04:33 GMT
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.

Mime
View raw message