Mahmoud created IGNITE-10982:
--------------------------------
Summary: Kafka Ignite connect module listen to all related cache
node events, not only the source cache
Key: IGNITE-10982
URL: https://issues.apache.org/jira/browse/IGNITE-10982
Project: Ignite
Issue Type: Bug
Components: general
Affects Versions: 2.7
Reporter: Mahmoud
Hey All ,
I see in Kafka module , in
IgniteSourceTask.java , we listen to all target cache node events not only the
source cache event , is it by design like that ? we should only listen to the
source cache events through continuous query:
[https://apacheignite.readme.io/docs/continuous-queries]
As we current implementation , we catch all caches events the belong to the
same source cache node , not only the configured source cache name:
code snippet from : IgniteSourceTask.java
{code:java}
rmtLsnrId = IgniteGrid.getIgnite().events(IgniteGrid.getIgnite().cluster()
.forCacheNodes(cacheName))
.remoteListen(locLsnr, rmtLsnr, evts);{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
