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 Mon, 05 Jun 2017 09:23:39 GMT
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.


> On 5 Jun 2017, at 07:59, ignitedFox [via Apache Ignite Users] <ml+s70518n13362h89@n6.nabble.com>
> 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

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.
View raw message