You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 静谧雨寒 <fr...@vip.qq.com> on 2020/09/30 01:44:55 UTC

flink1.11.1 kafka eos checkpoints失败：Timeout expired after 600000milliseconds

flink 1.9版本使用kafkaSemantic设置为EXACTLY_ONCE工作一直正常，前段时间升级到1.11后 ,checkpoints一直报等待InitProducerId超时，我还调整TransactionTimeout和MaxBlockMS无效
org.apache.kafka.common.errors.TimeoutException: Timeout expired after 600000milliseconds while awaiting InitProducerId
我查看了kafka事务配置发现运维使用的是默认配置，是否和kafka配置有关？offsets.topic.replication.factor=1

transaction.state.log.replication.factor=1

transaction.state.log.min.isr=1