Hi, you were very good busy above.
Let me try to explain you what needs to be done. 1) The method that you need to finish is the method you are overriding: 2) What you need to do here is first get the values you need out from the SinkRecord record. Look in the Kafka API how to do this. 3) First do step 2 and make sure you have the values so you can map them to the Integer and the Bus required for the output. The SinkRecord contains your data for "BUS_ID", "BUS_NUMBER", "BUS_DATE", etc. Use the Kafka API to get the values out of the SinkRecord (that is step 2). -- Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p13280.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
