/hazelcast-reactive-stream

Reactive CDC for Hazelcast IMDG (Proof of Concept)

Primary LanguageJava

It's a playground. Please don't use it. It's not suitable for production.

Capture changes happening in the IMDG data structures and consume as Project Reactor's Flux:

    IMap<Long, String> map = instance.getMap("map");
    Flux<EntryEvent<Long, String>> eventStreamForMap = instance.getEventStreamForMap(map);

    eventStreamForMap
        .log()
        .doOnNext(logAssignments())
        .take(Duration.ofMinutes(1))
        .blockLast();