Or are you saying I need to write custom streamer? On the streamer how do we get notified of data coming in? The examples don't show that. They only show how to connect... Or is that the only function of streamer?
On Fri, Mar 22, 2019, 9:12 AM John Smith, <[email protected]> wrote: > 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/ >> >
