【kafka】Attempted to write a non-default produerId at version 1

以你之姓@ 2022-09-09 06:57 279阅读 0赞

文章目录

  • 1.概述

在这里插入图片描述

1.概述

Flink 消费写入 kafka 运行了一天后才会报这个错,且其他程序都有写kafka,都无问题,怀疑是 cdc 造成的,其他程序未使用cdc,然后报错如下
在这里插入图片描述
看报错在
在这里插入图片描述
这个里面 但是我却找不到这个属于哪个包,客户端和服务端代码都查了一遍,找不到错误在那里,没得解决

我验证了一下你这个报错的代码 大概是 根据一个json生成一个实体类

发表评论

表情:
评论列表 (有 0 条评论,279人围观)

还没有评论,来说两句吧...

相关阅读