代码发生变化就不能用了?没说清楚啊。。。

来源:15-6 -offset管理演示二

哆啦A梦爱学习吖

2020-09-06

如题。

写回答

1回答

Michael_PK

2020-09-06

代码发生了变化,checkpoint里面的东西就发生变化,就不行了。所以得自己维护offset。你可以参考最新上线的那套spark3流处理的项目,从头到尾讲了解决方案和代码实现

0
0

Spark Streaming实时流处理项目实战

Flume+Kafka+Spark Streaming 构建通用实时流处理平台

1404 学习 · 571 问题

查看课程