ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mahmoud (JIRA)" <j...@apache.org>
Subject [jira] [Created] (IGNITE-10982) Kafka Ignite connect module listen to all related cache node events, not only the source cache
Date Fri, 18 Jan 2019 14:03:00 GMT
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)

Mime
View raw message