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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

akira
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