ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From John Smith <java.dev....@gmail.com>
Subject Re: Best way to upsetting/delete records in Ignite from Kafka Stream?
Date Fri, 22 Mar 2019 13:17:13 GMT
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, <java.dev.mtl@gmail.com> 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, <aealexsandrov@gmail.com>
> 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/
>>
>

Mime
View raw message