如何强制Ignite节点从数据库而非集群现有节点加载数据？

• 部署3个Ignite实例（A、B、C）：
  • 实例A连接PostgreSQL数据库，B、C仅从A同步缓存数据
  • 部署顺序为先启动A，再启动B、C
• 故障场景：A因网络问题宕机1分钟，期间PostgreSQL发生的数据变更无法同步到B、C；A恢复后，未从数据库加载最新数据，反而同步了B、C节点的陈旧数据
• 补充说明：所有缓存更新均通过PostgreSQL触发器触发通道，由Ignite上的应用捕获事件完成，不直接写入缓存
• 尝试过的无效方案：将A的Rebalance模式设为NONE，B、C保持默认ASYNC，但Ignite要求集群内所有节点的Rebalance模式必须一致，配置无法生效

相关配置代码：

val discoverySpi = TcpDiscoverySpi()

val ipFinder = TcpDiscoveryVmIpFinder()

ipFinder.setAddresses(clusterIPs?.split(",") ?: listOf())
ipFinder.setShared(true)
discoverySpi.setIpFinder(ipFinder)

val igniteConfig = IgniteConfiguration()

igniteConfig.discoverySpi = discoverySpi

igniteConfig.metricsLogFrequency = 0 
igniteConfig.setClientMode(false)
igniteConfig.igniteInstanceName = System.getenv("ignite.instance-name")
val atomicConfiguration = AtomicConfiguration()
atomicConfiguration.cacheMode = CacheMode.REPLICATED
igniteConfig.atomicConfiguration = atomicConfiguration
igniteConfig.setCacheConfiguration("Model Name".cacheConfiguration.setRebalanceMode(CacheRebalanceMode.NONE))

方案1：A节点恢复时主动加载数据库增量数据 #

在A节点启动完成（或恢复连接到集群）后，执行自定义加载逻辑：

1. 通过Ignite的节点生命周期监听器LifecycleBean捕获节点停止/启动事件，记录A节点的宕机时间戳
2. 基于该时间戳，查询PostgreSQL中对应时间段内的所有变更记录
3. 调用IgniteCache.putAll()将增量数据写入缓存，B、C会通过Replicated模式自动同步最新数据
4. 若使用CacheStore，可重载loadCache()方法，传入时间范围参数实现增量加载

方案2：统一Rebalance模式，自定义数据同步逻辑 #

由于Ignite要求集群内Rebalance模式一致，可将所有节点的Rebalance模式设为NONE，然后实现自定义同步逻辑：

1. 在B、C节点上通过IgniteCluster.addListener()监听A节点的状态变更事件
2. 当检测到A节点恢复上线后，触发A节点执行DB数据刷新操作
3. A节点刷新完成后，通过Ignite的compute() API让B、C节点主动拉取A的最新缓存数据

方案3：引入事件持久化队列避免丢失变更 #

修改PostgreSQL触发器的事件通道，加入消息队列实现事件持久化：

1. 触发器触发的DB变更事件先写入持久化消息队列（如Kafka、RabbitMQ）
2. A节点正常运行时实时消费队列事件，更新缓存并同步给B、C
3. A宕机期间，事件在队列中累积；A恢复后，先消费队列中未处理的事件，更新本地缓存后再同步给B、C

内容的提问来源于stack exchange，提问作者Kartikey Srivastava