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:
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
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
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
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
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
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,
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.
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