ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aealexsandrov <aealexsand...@gmail.com>
Subject Re: Best way to upsetting/delete records in Ignite from Kafka Stream?
Date Fri, 15 Mar 2019 20:48:28 GMT
Hi,

You can use the Kafka streamer for these purposes:

https://apacheignite-mix.readme.io/docs/kafka-streamer

Also, take a look at this thread. It contains examples of how to work with
JSON files:

http://apache-ignite-users.70518.x6.nabble.com/Kindly-tell-me-where-to-find-these-jar-files-td12649.html

According to UPSERT specific. You should set the allowoverride flag to the
IgniteStreamer used by KafkaStreamer (otherwise it will be INSERT specific).
You can do it using the next methods:

https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/stream/StreamAdapter.html#getStreamer--
https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/stream/StreamAdapter.html#setStreamer-org.apache.ignite.IgniteDataStreamer-

BR,
Andrei



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Mime
View raw message