我们正在尝试实现两个Ignite数据集群之间的数据复制。
为此,我们正在使用Kafka Connect。
我们遵循了本文档中提到的内容->https://dzone.com/articles/linking-apache-ignite-and-apache-kafka-for-highly
在我们使用一个缓存和PUT操作之前,一切都很好。
但是,当我使用相同的REMOVED操作时,在连接器的使用者线程中,我可以看到CacheEvent记录,但数据并没有从Sink Cluster节点中删除。
有人能帮忙处理这个案子吗?
Ignite-Kafka集成可能存在问题。尝试收集所有相关详细信息,并通过用户列表向Ignite社区报告。
同时,如果问题没有得到解决,您可以考虑其他复制选项:
- 通过认证的GridGain Kafka Connect集成进行复制
- GridGain的数据中心复制功能