Aditya created IGNITE-15258:
-------------------------------
Summary: IgniteSourceTask code issue
Key: IGNITE-15258
URL: https://issues.apache.org/jira/browse/IGNITE-15258
Project: Ignite
Issue Type: Bug
Reporter: Aditya
[https://github.com/apache/ignite-extensions/blob/master/modules/kafka-ext/src/main/java/org/apache/ignite/stream/kafka/connect/IgniteSourceTask.java#L167]
we have a 3 node setup, where 2 nodes are ignite servers and the other node is
kafka connect source process which will be connected to those 2 nodes. So total
3 ignite nodes in baseline topology.
In the above code I've used custom class filter and set it via cacheFilterCls.
Now while executing queries on caches with "Replication" mode, the custom cache
filter is working only on 3rd node but not on other 2 nodes.
In other words the custom filter is applied only for keys of cache that 3rd
node is primary of. Seems the class is not running on other 2 nodes.
can someone please check this.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
