Reliable Topic Connector

Reliable Topic provides a simple pub/sub messaging API which can be used as a data sink within a pipeline.

Installing the Connector

This connector is included in the full and slim distributions of Hazelcast.

Permissions

Enterprise EditionThis feature requires Hazelcast Enterprise, a licensed edition of the Hazelcast Platform.

If security is enabled, you can set up permissions to restrict clients' access to these data structures. For details, see Client Authorization.

Reliable Topic as a Source or Sink

java

hz.getReliableTopic("topic")
   .addMessageListener(message -> System.out.println(message));

Pipeline p = Pipeline.create();
p.readFrom(TestSources.itemStream(100))
  .withIngestionTimestamps()
  .writeTo(Sinks.reliableTopic("topic"));

A simple example is supplied above. For a more advanced version, also see Observables.