I hope to try something next week. Maybe you can help me out setup a database and extraction from it with kafka to reproduce the extraction in to Kafka and getting it into ignite. I will be using SQLite.
Humphrey > On 5 Jun 2017, at 07:59, ignitedFox [via Apache Ignite Users] > <[email protected]> wrote: > > Hi, I tried to extract SinkRecord value like below; > > public class MyExtractor implements StreamSingleTupleExtractor<SinkRecord, > Integer, Bus> { > @Override > public Entry<Integer, Bus> extract(SinkRecord record) { > System.out.println("output starts\n\n\n\n\n\n\n\n"); > System.out.println(record); > System.out.println("output ends\n\n\n\n\n\n\n\n\n\n"); > System.out.println(record.getClass().getCanonicalName()); > return null; > } > > } > > Nothing is getting printed. Is it possible to reproduce the flow? > > Or somebody kindly suggest me some code, to sync a simple string record, that > I have inserted into Kafka, using kafka-console-producer and insert it to > Ignite. > > Thanks a ton. > > If you reply to this email, your message will be added to the discussion > below: > http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p13362.html > To unsubscribe from How to solve SinkRecord cannot be cast exception? > [unsolved], click here. > NAML -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/How-to-solve-SinkRecord-cannot-be-cast-exception-unsolved-tp13221p13363.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
