I've just noticed your Bus domain class above:
So your code will look like the following when you figure out how to extract your values from the SinkRecord record. The only thing you need to find out is how to extract the values from your record. Here I point you to check the Kafka documentation and the Kafka API. It's good for you to do that so you learn how to do things. -- Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p13297.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
