[
https://issues.apache.org/jira/browse/IGNITE-13424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Belyakov closed IGNITE-13424.
----------------------------------
Ignite Flags: (was: Docs Required,Release Notes Required)
> 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)
