I am using an embeded version of Hazelcast 5.2.1 and I noticed that EntryProcessor executes on all cluster members.
In my entry processor, I have a logic which fetch some data from database (based on the data definition in the distributed map) and send the result into a bus. The problem is that I receive twice the same notification since the both cluster members execute the task.
Why the entry proccessor executes on both cluster members?
Is there a way to force the execution to only the key owner or at least that the entry processor is executed only once?
My entry processor definition:
public class myEntryProcessor implements EntryProcessor<String, SerializableSession, Void>, Offloadable, IdentifiedDataSerializable
Thank you for any help