Re: Kafka Streamer

2016-10-26 Thread Anil
Got you. thanks. On 27 October 2016 at 09:30, vkulichenko wrote: > I changed the definition of the class (generic types, in particular). > Compilation will be broken for those who already use KafkaStreamer. > > -Val > > > > -- > View this message in context:

Re: Kafka Streamer

2016-10-26 Thread vkulichenko
I changed the definition of the class (generic types, in particular). Compilation will be broken for those who already use KafkaStreamer. -Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Kafka-Streamer-tp8432p8532.html Sent from the Apache Ignite Users

Re: Kafka Streamer

2016-10-26 Thread Anil
Looks perfect. Could you please elaborate "this change breaks API compatibility" ? Thanks On 27 October 2016 at 01:42, vkulichenko wrote: > Hi, > > OK, I see now what you mean and it looks like this is not supported right > now. I created a ticket [1], however the

Re: Kafka Streamer

2016-10-26 Thread vkulichenko
Hi, OK, I see now what you mean and it looks like this is not supported right now. I created a ticket [1], however the way I propose it will break API compatibility, so can be done only in 2.0. If you have any other suggestions, feel free to add comments. For now you can create your own consumer

Re: Kafka Streamer

2016-10-25 Thread Anil
HI Val, in my case, kafka message key and value (actual message) are strings. I used decoders for key and value as StringDecoder. but value is not the value of cache and key is to maintain the order of the messages in kafka, it is not actual key of the cache. Message is json object which is

Re: Kafka Streamer

2016-10-25 Thread vkulichenko
Anil, Decoders convert binary message from Kafka to a key-value pair. Streamer then redirects this pair to cache. Why doesn't this work for you? -Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Kafka-Streamer-tp8432p8481.html Sent from the Apache Ignite

Re: Kafka Streamer

2016-10-25 Thread Anil
Should we use Tuple Extractor ? i still need to look at code and give a try. On 25 October 2016 at 09:18, Anil wrote: > No Val. A message cannot be converted into number of cache entries using > value decoder. am i wrong ? > > Thanks. > > On 25 October 2016 at 02:42,

Re: Kafka Streamer

2016-10-24 Thread Anil
No Val. A message cannot be converted into number of cache entries using value decoder. am i wrong ? Thanks. On 25 October 2016 at 02:42, vkulichenko wrote: > Hi, > > There are keyDecoder and valueDecoder that you can specify when creating > the > KafkaStreamer.

Re: Kafka Streamer

2016-10-24 Thread vkulichenko
Hi, There are keyDecoder and valueDecoder that you can specify when creating the KafkaStreamer. Is that what you're looking for? -Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Kafka-Streamer-tp8432p8447.html Sent from the Apache Ignite Users mailing list