Hi, It shouldn't work like you described: Continuous query clients should only be receiving the records that are pertinent to their filters/transformers.
verify the continuous query definitions using the appropriate view: https://apacheignite.readme.io/docs/continuous_queries take a look at : https://apacheignite.readme.io/docs/continuous-queries and the example here: https://github.com/apache/ignite/blob/master/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java Send a reproducer (And the version you are on) and I'll take a look. Thanks, Alex -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/