What did the System.out.println(record.value()); print out in the console? You let say that record.value() gave you an object named Car which should have a method getColor and getId. Then you should could call the method from getColor to get the color of the Car (which comes from SinkRecord value) and map that to your Bus, setColor.
First thing you need to do is get the values you want from the record.value object. Look in the API that was given from Kafka how to do that. Once you have those values you can map them to your Bus object. When you have the id value and the Bus object fill you create new AbstractMap.SimpleEntry<Integer, Bus>(id, bus); where id is the bus_id you got from the the object and the bus object you created in the step above. -- Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p13275.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
