FlinkFlink exactly-once 报错 Timeout expired after 60000 milliseconds while awaiting InitProducerId(代码

Posted 2021-09-06 九师兄

文章目录

• 1.概述
• 2.源码分析

1.概述

flink 开启了exactly-once，设置了transaction.id
然后flink一直不停重启，一直报错

org.apache.kafka.common.errors.TimeoutException: org.apache.kafka.common.errors.TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

界面还有如下的debug问题

taskManager的日志中，只有这一个错误，其它