Spark Streaming】如何保证sparkstreaming在消费kafka数据的时候的语义一致性?

2020-08-25 08:59发布

1条回答
milkmilk
2楼 · 2020-08-26 15:59
  1. 输入的数据来自可靠的数据源和可靠的接收器;

  2. 2. 应用程序的metadata被application的driver持久化了(checkpointed );

  3. 启用了WAL特性(Write ahead log)。


相关问题推荐

    没有解决我的问题,去提问