You can just wrap your IgniteDataStreamer instance, override addData() method and pass this wrapper instance to your streamer (I suspect it is KafkaStreamer). All conversions you can execute in overriden addData() method.
On Thu, Jan 12, 2017 at 7:40 AM, rishi007bansod <[email protected]> wrote: > So, you are suggesting generics in streamadaptor should be modified to > <object,object> from <string,string> in my case? But keydecoder and > valuedecoder used with stream allows only string(or byte array) format > > > > -- > View this message in context: > http://apache-ignite-users.70518.x6.nabble.com/Convert-stream-data-key-value-tp10033p10050.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com.
