You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Igor Belyakov (Jira)" <ji...@apache.org> on 2020/09/11 14:45:00 UTC
[jira] [Resolved] (IGNITE-13424) Ignite Sink Task issue in Kafka
integration
[ https://issues.apache.org/jira/browse/IGNITE-13424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Igor Belyakov resolved IGNITE-13424.
------------------------------------
Resolution: Duplicate
Ticket for the improvement was created.
> Ignite Sink Task issue in Kafka integration
> -------------------------------------------
>
> Key: IGNITE-13424
> URL: https://issues.apache.org/jira/browse/IGNITE-13424
> Project: Ignite
> Issue Type: Bug
> Components: streaming
> Affects Versions: 2.8.1
> Reporter: Aditya
> Priority: Major
>
> We are trying to implement the replication of data between two Ignite data clusters.
> For this purpose, we are using Kafka Connect.
> We have followed the things mentioned in this document -> [https://dzone.com/articles/linking-apache-ignite-and-apache-kafka-for-highly]
> Everything is working fine till we use one cache and PUT operation.
> But when I use the same for REMOVED operation, in the consumer thread of the connector, I can see the CacheEvent record, but the data is not being removed from the Sink Cluster nodes.
> When checked, the remove functionality is missing in IgniteSinkTask class.
> Is IgniteSink connector only for injecting data? The data record type at the receiving end is of type CacheEvent. Based on the operation it should put or remove right? As of now only, PUT is working.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)