|
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
|