You mean I need to write my own Kafka connect connector using the cache API and from there decide to do put or remove?
On Tue, Mar 19, 2019, 8:02 PM aealexsandrov, <[email protected]> wrote: > Hi, > > Yes, looks like the KafkaStreamer doesn't support the DELETE behavior. It > was created to loading data to Ignite. > > However, deleting data from Ignite is possible using Interface > IgniteDataStreamer API: > > > https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/IgniteDataStreamer.html#removeData-K- > > So you just require to proceed the Kafka stream and use IgniteDataStreamer > (or IgniteCache API) somewhere in sink function. Possible that you should > take a look at Kafka connector: > > https://kafka.apache.org/documentation.html#quickstart_kafkaconnect > > BR, > Andrei > > > > -- > Sent from: http://apache-ignite-users.70518.x6.nabble.com/ >
