通过Kafka Connect为Apache Ignite进行DC复制



我们正在尝试实现两个Ignite数据集群之间的数据复制。

为此,我们正在使用Kafka Connect。

我们遵循了本文档中提到的内容->https://dzone.com/articles/linking-apache-ignite-and-apache-kafka-for-highly

在我们使用一个缓存和PUT操作之前,一切都很好。

但是,当我使用相同的REMOVED操作时,在连接器的使用者线程中,我可以看到CacheEvent记录,但数据并没有从Sink Cluster节点中删除。

有人能帮忙处理这个案子吗?

Ignite-Kafka集成可能存在问题。尝试收集所有相关详细信息,并通过用户列表向Ignite社区报告。

同时,如果问题没有得到解决,您可以考虑其他复制选项:

  1. 通过认证的GridGain Kafka Connect集成进行复制
  2. GridGain的数据中心复制功能

相关内容

  • 没有找到相关文章

最新更新