【发布时间】:2021-06-30 21:06:01
【问题描述】:
https://issues.apache.org/jira/browse/IGNITE-13442
关于上述问题,尚未实施/修复。
或者,在 Sink Connector 的地方,我们可以编写自己的消费者来监听 Kafka 队列的缓存事件吗?这些消费者将在哪里检查这些事件并在指定的集群上执行以进行 DC 复制。
【问题讨论】:
标签: apache-kafka apache-kafka-connect ignite
https://issues.apache.org/jira/browse/IGNITE-13442
关于上述问题,尚未实施/修复。
或者,在 Sink Connector 的地方,我们可以编写自己的消费者来监听 Kafka 队列的缓存事件吗?这些消费者将在哪里检查这些事件并在指定的集群上执行以进行 DC 复制。
【问题讨论】:
标签: apache-kafka apache-kafka-connect ignite
由于 Ignite 是开源的,因此自己修复它可能比从头开始编写自己的消费者更容易。
话虽如此,Kafka 适配器并没有什么“特别”之处。完全可以编写一个从 Kafka 读取数据并将 put 或 removes 发送到 Ignite 集群的应用程序。
【讨论】: