我们正在尝试实现两个ignite数据集群之间的数据复制。
为此，我们正在使用Kafka连接。
我们遵循了本文档中提到的内容->https://dzone.com/articles/linking-apache-ignite-and-apache-kafka-for-highly
在我们使用一个缓存和put操作之前，一切都正常。
但是，当我对removed操作使用相同的方法时，在连接器的使用者线程中，我可以看到cacheevent记录，但是数据没有从sink集群节点中删除。
有人能帮忙处理这个案子吗？
1条答案
按热度按时间ezykj2lf1#
这可能是点火Kafka整合的一个问题。尝试收集所有相关细节，并通过用户列表向ignite社区报告。
同时，如果问题没有解决，您可以考虑其他复制选项：
通过认证的gridgain kafka connect集成进行复制。
gridgain提供的数据中心复制功能。