【发布时间】:2020-09-10 06:27:17
【问题描述】:
我们正在尝试实现两个 Ignite 数据集群之间的数据复制。
为此,我们使用 Kafka Connect。
我们已经遵循了本文档中提到的内容 -> https://dzone.com/articles/linking-apache-ignite-and-apache-kafka-for-highly
在我们使用一个缓存和 PUT 操作之前一切正常。
但是当我使用相同的 REMOVED 操作时,在连接器的消费者线程中,我可以看到 CacheEvent 记录,但数据并未从 Sink Cluster 节点中删除。
有人可以帮忙处理这个案子吗?
【问题讨论】:
标签: apache-kafka ignite apache-kafka-connect