Flink producer attempted to use a producer id which is not currently assigned to its transaction(代码片
Posted 九师兄
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink producer attempted to use a producer id which is not currently assigned to its transaction(代码片相关的知识,希望对你有一定的参考价值。
1.场景1
1.1 概述
我是 cancel savepoint 之后重启不行,直接启动又没事
cancel savepoint 之后重启不行 指定了 从savepoint, -s 指定了 地址
就是要 恢复状态,然后 就出现上述错误
错误如下:Caused by: org.apache.kafka.common.errors.InvalidPidMappingException: The producer attempted to use a producer id which is not currently assigned to its transactional id.
这个 kafka sink的参数 参数如下
以上是关于Flink producer attempted to use a producer id which is not currently assigned to its transaction(代码片的主要内容,如果未能解决你的问题,请参考以下文章
Flink - Kafka 下发消息过大异常分析与 Kafka Producer 源码浅析
FlinkFlink kafka producer 分区策略 (flink写入数据不均匀 与 数据写入 分区无数据 )
从0到1Flink的成长之路(二十)-Flink 高级特性之自动重启策略和恢复