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/
