I'm not sure how your Bus class is implemented. For sure you won't be needing those private methods. If that Bus class represends that Object you are getting as record (SinkRecord) then you can cast that object to Bus.
Still you are not using the Kafka API to extract your values, you are just casting the record (SinkRecord) you are receiving to Bus, which if it's not an instance of Bus it won't work. -- Humphrey -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p13290.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
