Hazelcast topic - messages seem to be sent from only one member
I am using hazelcast cluster in client server mode. There are two members in the cluster.
From one client, I am publishing messages to topic and from other clients I am trying to receive messages from the topic.
In management center , it is shown that all operations are performed in only one instance.
Is this the expected behavior ? I would expect publishes and receives in both members
Regards
I see same question is answered on google groups. As an addition to that answer, please keep in mind that ITopic is a non-partitioned data structure which means it is stored on a single partition (=single member). That's why you see all pub/sub related to that topic happens on a single member.
On the other hand, if you have a topic use-case I'd like to let you know about ReliableTopic as well, it has better guarantees but that might come with an overhead, obviously.
- Keep numbers which appear in both columns, in J lang
- Differentiation in J
- How to reshape an array with an arbitrary size in one dimension?
- Why is Insert (fold) right associative
- Write 4 : 'x&{.&.;: y' tacitly
- Alignment issue when printing formatted prime numbers in J language
- How can I define a verb in J that applies a different verb alternately to each atom in a list?
- How to get user input in the J programming language
- How to unbox a list of boxed lists of differing lengths in J?
- How can I fix 'noun result was required' error in J?
- In j, how can I define a verb locally in one scope and pass it to a defined adverb?
- Convert boxed array to normal array?
- Read column of CSV file as array
- Replace atom in array of strings
- What does the dyad `=` do to boxed strings?
- Index of minimum element using J
- How can I take the outer product of string vectors in J?
- Building an array of verbs in J
- Reading in multidigit command line parameter
- Amend with bond to new data shows unexpected behaviour
- How to turn a table or matrix into a (flat) list in J
- How to run dissect in J?
- How to define selection using index function in J
- How to exit the J console?
- Find 4-neighbors using J
- Writing custom verbs in J
- How do I negate a selector in J lang?
- How to use arbitrary selector in interchange in J lang?
- different result once square root is added inside tacit
- Sum of arrays with repeated indices