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, 31 May 2017 13:06:49 GMT
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.

Mime
View raw message