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

官网在kafka连接描述:

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

 

中文版:

 

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

 

 

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

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

 

相关文章:

  • 2021-10-04
  • 2021-10-19
  • 2021-06-22
  • 2022-12-23
  • 2021-09-26
  • 2021-08-08
  • 2021-09-06
  • 2021-09-23
猜你喜欢
  • 2021-12-04
  • 2021-08-08
  • 2022-02-08
  • 2022-02-08
  • 2021-10-11
  • 2022-12-23
  • 2022-12-23
相关资源
相似解决方案