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/
