flink:重启job,会重复消费kafka。

重启了job,然后发现mysql库里数据不对,重复消费了。

官网在kafka连接描述:

中文版:

 

 解决方案:手动维护kafka偏移量。

https://www.cnblogs.com/niutao/p/10948919.html

原文地址:https://www.cnblogs.com/fishperson/p/13821955.html